請教大牛個問題：多線程若線程2正鎖住mutex，此時線程1使用pthread_mutex_try()作用？

251300891

請教大牛一個問題：
共享全局變量

static int g_int=0;
static pthread_mutex_t mutex;

線程1:

1.     int ret = pthread_mutex_trylock(&mutex);                        //try lock
   
2.     [size=5][color=Magenta]如何設(shè)置等待mutex時間？[/color][/size]
   
3. 
   
4.     if (ret == EBUSY){
   
5.                                     printf("pthread2:the variable is locked by pthread1\n");
   
6.     被其他線程使用時，緩存動作
   
7. 
   
8.     } else if (ret != 0) {
   
9.                                     perror("pthread_mutex_trylock");
   
10.                                     exit(1);
    
11.     } else {
    
12.                                     printf("pthread2:pthread2 got lock.\n");
    
13.     馬上設(shè)g_int=1;
    
14.                                     pthread_mutex_unlock(&mutex);
    
15.     }

復(fù)制代碼

復(fù)制代碼
線程2:

1.     pthread_mutex_lock(&mutex);
   
2.     //do something
   
3.     //處理時間比較長
   
4.     g_int=1;
   
5.     pthread_mutex_unlock(&mutex)
   

復(fù)制代碼

復(fù)制代碼
若線程2正鎖住mutex時，此時線程1使用pthread_mutex_trylock()會立即返回嗎？
可以讓thread_a設(shè)置等待mutex鎖的時間嗎？pthread_cond_timedwait等有設(shè)計過的嗎？

251300891

blake326

pthread_mutex_lock()系列好像沒有超時等待的吧。不記得了。

線程1要超時的話，一般是pthread_mutex_lock阻塞住，然后搞一個定時器吧。次奧，不記得了什么api了，不過倒是用過alarm信號的，一點也不好用。

blake326

好像linux 用戶態(tài)真沒有什么現(xiàn)成的timer api呢。怪不得我以前用了alarm。

可以借鑒內(nèi)核設(shè)計，在用戶態(tài)創(chuàng)建一個timer線程專門提供timer功能。

timer線程主要維護一個紅黑樹，管理所有timer，key的話是超時的絕對秒數(shù)。然后一個死循環(huán)，通過select睡眠一個最近的超時時間。當select超時返回時，檢測紅黑樹上所有超時的timer，進行回調(diào)處理。如果注冊了一個timer要比當前最近的timer更早的超時的話，則要讓發(fā)一個信號讓select立即返回，檢查是否要處理超時時間，并且更新最新的睡眠時間。

提供timer api貌似也得有一個線程。

251300891

回復(fù) 4# blake326


   

junnyg

回復(fù) 4# blake326
內(nèi)核在用戶態(tài)提供了POSIX TIMER API：
基于 2.6 版本內(nèi)核定時器的實現(xiàn) (Posix 實時定時器 )
Linux 自 2.6 開始，已經(jīng)開始支持 POSIX timer ［ 2 ］所定義的定時器，它主要由下面的接口構(gòu)成 :

清單 8. POSIX timer 接口
                               
#include <signal.h>
#include <time.h>

int timer_create(clockid_t clockid, struct sigevent *evp,
timer_t *timerid);
int timer_settime(timer_t timerid, int flags,
const struct itimerspec *new_value,
struct itimerspec * old_value);
int timer_gettime(timer_t timerid, struct itimerspec *curr_value);
int timer_getoverrun(timer_t timerid);
int timer_delete(timer_t timerid);

這套接口是為了讓操作系統(tǒng)對實時有更好的支持，在鏈接時需要指定 -lrt 。
timer_create(2): 創(chuàng)建了一個定時器。
timer_settime(2): 啟動或者停止一個定時器。
timer_gettime(2): 返回到下一次到期的剩余時間值和定時器定義的時間間隔。出現(xiàn)該接口的原因是，如果用戶定義了一個 1ms 的定時器，可能當時系統(tǒng)負荷很重，導(dǎo)致該定時器實際山 10ms 后才超時，這種情況下，overrun=9ms 。
timer_getoverrun(2): 返回上次定時器到期時超限值。
timer_delete(2): 停止并刪除一個定時器

詳見https://www.ibm.com/developerworks/cn/linux/l-cn-timers/