如何使用pthread_mutex_trylock？

Question

使用的tryLock：

FILE   *fp; 
pthread_mutex_t demoMutex; 

void * printHello (void* threadId) 
{ 
    pthread_mutex_trylock (&demoMutex); 

    pthread_t  writeToFile = pthread_self(); 
    unsigned short iterate; 
    for (iterate = 0; iterate < 10000; iterate++) 
    { 
     fprintf (fp, " %d ", iterate,   4); 
     fprintf (fp, " %lu ", writeToFile, sizeof (pthread_t)); 
     fprintf (fp, "\n",  writeToFile, 1); 
    } 

    pthread_mutex_unlock (&demoMutex); 
    pthread_exit (NULL); 
} 

，然後主（）：

int main() 
{ 
    pthread_t  arrayOfThreadId [5]; 
    int     returnValue; 
    unsigned int iterate; 

    fp = fopen ("xyz", "w"); 
    pthread_mutex_init (&demoMutex, NULL); 

    for (iterate = 0; iterate < 5; iterate++) 
    { 
     if (returnValue = pthread_create (&arrayOfThreadId [iterate], 
            NULL, 
            printHello, 
            (void*) &arrayOfThreadId [iterate]) != 0) 
     { 
      printf ("\nerror: pthread_create failed with error number %d", returnValue); 
     } 
    } 

    for (iterate = 0; iterate < 5; iterate++) 
     pthread_join (arrayOfThreadId [iterate], NULL); 

    return 0; 
} 

這裏輸出第一打印一些第一線，然後剩下的，然後又是第一個。鎖不起作用。如果我用pthread_mutex_lock替換它，每一件事情都會非常順序地顯示出來！

這裏有什麼可笑的錯誤？

Answer 1

在沒有測試結果的情況下調用pthread_mutex_trylock()沒有任何意義。

如果未能獲得互斥體，你應該不進入臨界區，你應該不後解鎖。例如，你可以重寫它像這樣（注意，您也即將fprintf()應該怎麼叫很迷惑）：

void *printHello(void *threadId) 
{ 
    if (pthread_mutex_trylock(&demoMutex) == 0) 
    { 
     unsigned short iterate; 
     for (iterate = 0; iterate < 10000; iterate++) 
     { 
      fprintf (fp, " %d\n", iterate); 
     } 

     pthread_mutex_unlock (&demoMutex); 
    } 

    pthread_exit (NULL); 
} 

但是，它可能更有意義使用pthread_mutex_lock()代替pthread_mutex_trylock()，讓你的線程將等待互斥體在爭用時可用。幾乎在所有情況下你都想要的東西是pthread_mutex_lock(); _trylock變體僅用於優化一些不尋常的情況 - 如果您遇到需要_trylock的情況，您將會知道。

Answer 2

該代碼旨在阻止以確保互斥您撥打pthread_mutex_trylock()。否則它是未定義的行爲。因此，您必須致電pthread_mutex_lock()。

Answer 3

用while循環鎖定的修改版本應該更穩定。

void *printHello(void *threadId) 

{ 

    while (pthread_mutex_trylock(&demoMutex) == 0) 

    { 

     unsigned short iterate; 

     for (iterate = 0; iterate < 10000; iterate++) 

     { 

      fprintf (fp, " %d\n", iterate); 

     } 


     pthread_mutex_unlock (&demoMutex); 

     break; 

    } 

pthread_exit (NULL); 

}`

Answer 4

... 
while (pthread_mutex_trylock(&demoMutex) == 0) 
... 

您的代碼是沒有意義的。它在哪裏被鎖定？這就像一個不工作的自旋鎖使用更多的CPU？！

的tryLock返回0時鎖定，所以：

if(!pthread_mutex_trylock(&demoMutex)) 
{ 
    // mutex locked 
} 

如果上 mutex引用的互斥對象鎖定獲取的pthread_mutex_trylock（）函數將返回零。否則，將返回一個錯誤 以指示錯誤。

Answer 5

pthread_mutex_trylock的使用用於確保tou不會導致競爭特定命令。 爲了做到這一點，您必須使用pthread_mutex_trylock作爲條件！一個不假設它會自行工作。 example- while（pthread_mutex_trylock（& my_mutex）== 0）{ printf（「互斥量在我的控制下！\ n「）; }

這樣你可以肯定的是，即使互斥已被鎖定，你正在做在特定線程abusy，等待它

Answer 6

咖啡館就如何偉大的答案我只需要自己解釋一下這個解釋，但是我確實知道pthread_mutex_lock()在課堂上有更多的開銷，並且使用<time.h> lib對它進行了測試，並且我的循環的性能得到了顯着提高，只需添加兩個美分，因爲他提到，也許你應該使用pthread_mutex_lock()來代替！

#include <pthread.h> 
#include <stdio.h> 
#include <stdlib.h> 
#include <time.h> 

#define NUM_THREADS 4 
#define LOOPS 100000 

int counter; 
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; 

// using pthread_mutex_lock 
void* worker() { 
    for (int i = 0; i < LOOPS; i++) { 
     pthread_mutex_lock(&mutex); 
     counter++; 
     pthread_mutex_unlock(&mutex); 
    } 
    pthread_exit(NULL); 
} 

// using try_lock - obviously only use one at a time 
void* worker() { 
    for (int i = 0; i < LOOPS; i++) { 
     while (pthread_mutex_trylock(&mutex) != 0) { 
      // wait - treated as spin lock in this example 
     } 

     counter++; 
     pthread_mutex_unlock(&mutex); 
    } 
    pthread_exit(NULL); 
} 

int main(int argc, char *argv[]) { 
    clock_t begin = clock(); 
    pthread_t t[NUM_THREADS]; 
    int rc; 

    counter = 0; 

    for (int i = 0; i < NUM_THREADS; i++) { 
     rc = pthread_create(&t[i], NULL, worker, NULL); 

     if (rc) { 
      printf("Thread #%d failed\n", i); 
     } 
    } 

    for (int i = 0; i < NUM_THREADS; i++) { 
     pthread_join(t[i], NULL); 
    } 

    printf("%d\n", counter); 
    clock_t end = clock(); 
    double time = (double)(end - begin)/CLOCKS_PER_SEC; 

    printf("Time Spent: %f", time); 

    return 0; 
} 

顯然你會評論一名工作人員來測試它，但如果你嘗試一下，我得到Time Spent: 1.36200作爲pthread_mutex_lock()和Time Spent: 0.36714爲pthread_mutex_trylock()的平均值。

如果您使用Atomics，速度會更快。