重點(diǎn)關(guān)注：誰(shuí)有能進(jìn)行進(jìn)程間控制的讀寫鎖的實(shí)現(xiàn)啊?

richardyang

要求能同步進(jìn)程，讀時(shí)允許其它進(jìn)程讀，不允許寫；寫時(shí)只允許持有寫鎖的進(jìn)行寫，其它的不能讀也不能寫。如果不能獲得鎖，則程序阻塞或超時(shí)控制。

試想數(shù)據(jù)庫(kù)對(duì)表的行鎖的控制應(yīng)該也是這種進(jìn)程間的共享鎖和互斥鎖的綜合。

不知道誰(shuí)知道這方面如何實(shí)現(xiàn)，比較實(shí)用的那種！�。�

[ 本帖最后由 richardyang 于 2008-12-30 16:32 編輯 ]

foochow

共享內(nèi)存+信號(hào)量，然后和你實(shí)現(xiàn)一般的讀寫鎖一樣了

foochow

或者直接用ACE_Process_Mutex

foochow

或者是用ACE_RW_Process_Mutex，它是用文件鎖來(lái)實(shí)現(xiàn)的

richardyang

我設(shè)計(jì)了一個(gè)，大概思路是這樣的，大家看有沒(méi)啥漏洞：
一個(gè)信號(hào)燈，四個(gè)成員
初始:    w1=1     寫信號(hào)量
         w2=0     防讀的寫信號(hào)量(用兩個(gè)來(lái)防止死鎖)
         r=0      讀信號(hào)量，0時(shí)才能獲得寫
         a=1      總控信號(hào)量的獲取

寫加鎖WriteLock()：        
0 lock a                                                     //獲取總控信號(hào)量
1 unlock w2                                               //置有寫信號(hào)，防止其它的讀
2 if try wait r=0                                          //快速查看是否有讀，用IPC_NOWAIT
    go ... 3                                                 //無(wú)讀，去檢測(cè)3步的寫信號(hào)量   
  else                                                      
      unlock a                                                //釋放總控信號(hào)量，轉(zhuǎn)為阻塞在r上
    wait r=0                                                 //改為!IPC_NOWAIT,等待無(wú)讀信號(hào)

3 if try lock w1                                             //快速查看無(wú)寫
     success                                                   成功，
     unlock a                                              //釋放總控信號(hào)量，依賴路徑是否是2的try，否則已經(jīng)釋放過(guò)了
  else                                                         否則
     lock w1 等待                                            //轉(zhuǎn)為長(zhǎng)等待，等w1，即無(wú)寫  
     
            
write   ... ...


寫解鎖WriteUnlock()：         
1 unlock w1                                                  //釋放防寫信號(hào)
2 lock w2                                                    //釋放防讀信號(hào)
      

讀加鎖ReadLock()：
0 lock a                                                     //獲取總控信號(hào)量
1  if try wait w2=0                                          //快速查看是否有寫，用IPC_NOWAIT
        go ... 2                                             //無(wú)寫，去2釋放總控信號(hào)量
     else                                                    //有寫
        unlock a                                             //釋放總控信號(hào)量，轉(zhuǎn)為等待w2信號(hào)賴寧嘎
        wait w2=0                                            //改為!IPC_NOWAIT,等待w2信號(hào)
        
2 unlock r                                                   //標(biāo)記為有讀
3 if !unlock a                                               //如果是1成功，則這里滿足條件，釋放總控
        unlock a


  read ... ...
  

讀解鎖ReadUnlock()：
1 lock r                                                     //標(biāo)記為無(wú)讀

[ 本帖最后由 richardyang 于 2008-12-30 18:02 編輯 ]

richardyang

沒(méi)用過(guò)ACE啊，而且用ACE_RW_Process_Mutex好像只是有個(gè)定義，還沒(méi)看見(jiàn)有實(shí)現(xiàn)的地方，文件鎖無(wú)法實(shí)現(xiàn)超時(shí)，在windows下沒(méi)用過(guò)啊。但是我這種鎖的實(shí)現(xiàn)"成本"太高了啊，數(shù)據(jù)庫(kù)的鎖好像都用不到這么多sem。

[ 本帖最后由 richardyang 于 2008-12-30 18:27 編輯 ]

converse

你要把這個(gè)鎖放在共享內(nèi)存或者mmap中,可以參考我的開(kāi)源項(xiàng)目ccache:http://code.google.com/p/commoncache/downloads/list

richardyang

主要的問(wèn)題是通知機(jī)制，如果只是當(dāng)成一個(gè)計(jì)數(shù)，放在共享內(nèi)存肯定就可以了。主要是當(dāng)查看共享內(nèi)存，比如查看當(dāng)前不滿足條件時(shí)如何等到條件滿足并解除阻塞。
另外老兄的這個(gè)pthread_rwlock_wait也是不支持超時(shí)啊，況且Pthread庫(kù)在不同平臺(tái)下實(shí)現(xiàn)也不一樣，并不是都能同步進(jìn)程啊。
不知道還有更好的沒(méi)？

converse

>>況且Pthread庫(kù)在不同平臺(tái)下實(shí)現(xiàn)也不一樣，并不是都能同步進(jìn)程啊
這個(gè)我還是第一次聽(tīng)說(shuō),我關(guān)注一下這個(gè)問(wèn)題.

todaygood

實(shí)現(xiàn)原理應(yīng)該類似于linux內(nèi)核中的自旋鎖（讀寫自旋鎖），沒(méi)有獲得鎖則忙等直到獲得，但自旋鎖沒(méi)有超時(shí)控制。

pthread.h中有類似的函數(shù)，不過(guò)我沒(méi)用過(guò)(做應(yīng)用程序比較少),下面的 pthread_rwlock_timedwrlock 這個(gè)函數(shù)有超時(shí)處理。

extern int pthread_rwlock_init (pthread_rwlock_t *__restrict __rwlock,
                                __const pthread_rwlockattr_t *__restrict
                                __attr) __THROW __nonnull ((1));

/* Destroy read-write lock RWLOCK.  */
extern int pthread_rwlock_destroy (pthread_rwlock_t *__rwlock)
     __THROW __nonnull ((1));

/* Acquire read lock for RWLOCK.  */
extern int pthread_rwlock_rdlock (pthread_rwlock_t *__rwlock)
     __THROW __nonnull ((1));

/* Try to acquire read lock for RWLOCK.  */
extern int pthread_rwlock_tryrdlock (pthread_rwlock_t *__rwlock)
  __THROW __nonnull ((1));

# ifdef __USE_XOPEN2K
/* Try to acquire read lock for RWLOCK or return after specfied time.  */
extern int pthread_rwlock_timedrdlock (pthread_rwlock_t *__restrict __rwlock,
                                       __const struct timespec *__restrict
                                       __abstime) __THROW __nonnull ((1, 2));
# endif

/* Acquire write lock for RWLOCK.  */
extern int pthread_rwlock_wrlock (pthread_rwlock_t *__rwlock)
     __THROW __nonnull ((1));

/* Try to acquire write lock for RWLOCK.  */
extern int pthread_rwlock_trywrlock (pthread_rwlock_t *__rwlock)
     __THROW __nonnull ((1));

# ifdef __USE_XOPEN2K
/* Try to acquire write lock for RWLOCK or return after specfied time.  */
extern int pthread_rwlock_timedwrlock (pthread_rwlock_t *__restrict __rwlock,
                                       __const struct timespec *__restrict
                                       __abstime) __THROW __nonnull ((1, 2));
# endif
                                    __abstime) __THROW __nonnull ((1, 2));
#endif