0

条件変数と rwlock を使用する単純なスレッド プログラムがあります。さまざまなアプローチを試しながら、何時間もそれを見つめてきました。問題は、スレッドが書き込みロックされていないにもかかわらず、しばらくすると rwlock で停止することです。これらのロックがどのように機能するか、またはそれらがどのように実装されるかについて、私は何かを見逃しているかもしれません。

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

//global variables
pthread_mutex_t mutex;
pthread_cond_t cond;
pthread_rwlock_t rwlock;
int counter;
int listLength = 1;

void* worker(void* arg){
   do {
      usleep(200);
      printf("Before rwlock\n");
      pthread_rwlock_rdlock(&rwlock);
      printf("Before mutex\n");
      pthread_mutex_lock(&mutex);
      printf("Afer mutex\n");
      counter++;
      //signal the main
      if (counter == 5 ||
               (listLength < 5 && counter == listLength)){
          printf("Signal main\n");
          pthread_cond_signal(&cond);
          counter = 0;
      }
      pthread_mutex_unlock(&mutex);
      pthread_rwlock_unlock(&rwlock);
   } while(listLength != 0);

   return NULL;
}


int main(int argc, char* argv[]){
    if (argc != 2){
        perror("Invalid number of args");
        exit(1);
    }
    //get arguments
    int workers = atoi(argv[1]);

    //initialize sync vars
    pthread_rwlockattr_t attr;
    pthread_rwlockattr_setkind_np(&attr,
            PTHREAD_RWLOCK_PREFER_WRITER_NONRECURSIVE_NP);
    pthread_mutex_init(&mutex, NULL);
    pthread_cond_init(&cond, NULL);
    pthread_rwlock_init(&rwlock, &attr);
    counter = 0;

    //create threads
    pthread_t threadArray[workers];
    int threadOrder[workers];
    for (int i = 0; i < workers; i++){
        threadOrder[i] = i;
        if (pthread_create(&threadArray[i], NULL,
                    worker, &threadOrder[i]) != 0){
            perror("Cannot create thread");
            exit(1);
        }
    }

    while(listLength != 0) {
        //wait for signal and lock the list
        pthread_mutex_lock(&mutex);
        while (pthread_cond_wait(&cond, &mutex) != 0);
        pthread_rwlock_wrlock(&rwlock);
        printf("In write lock\n");

        pthread_mutex_unlock(&mutex);
        pthread_rwlock_unlock(&rwlock);
        printf("release wrlock\n");
    }

    //join the threads
    for (int i = 0; i < workers; i++){
        if (pthread_join(threadArray[i], NULL) !=0){
            perror("Cannot join thread");
           exit(1);
        }
    }

    //release resources
    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond);
    pthread_rwlock_destroy(&rwlock);

    return 0;
}
4

1 に答える 1

1

このコードにはいくつかの矛盾があるようです。

  1. これは、この種のすべてのスレッドが常にロックされていることを意味しmutexます。rwlockコードを削除してもrwlock、動作は変わりません。

  2. 電話が見えませんpthread_rwlock_init()。別の場所で電話をかけたとします。とにかく、それを呼び出すことに注意してください。同じ行ロック オブジェクトで 2 回以上呼び出さないようにしてください。

    同じことが当てはまりますpthread_rwlockattr_destroy()

  3. pthread_rwlock_rdlock() が書き込みロックなしでブロックする理由がわかりません。絶対にしないでください。または、相互ロックを行うことができますmutex

于 2013-11-10T09:35:21.653 に答える