すべてのスレッドが1つのジョブを終了してから別のジョブを終了するまで待ちます

Question

NUM_TREADSスレッドがあり、job2()を実行する前にjob1()を完了しなければならないとします。このように、これが起こることを保証する方法：

void thread_func(void *arg) 
{ 
    while(1) { 
     job1(); 
     some_kind_of_waiting(); 
     job2(); 
    } 
    return NULL; 
} 

が作業を以下またはその他の/より良い解決策があるようなセマフォウィル？

{ 
    static int done; 
    static sem_t semaphore; 

    if(__sync_fetch_and_add(&done, 1) == THREAD_NUMS-1) { 
     done = 0; 
     for(i = 0; i < THREAD_NUMS-1; i++) 
      sem_post(&semaphore); 
    } else 
     sem_wait(&semaphore); 
} 

ありがとう。

Answer 1

これは、pthreadsの障壁が解決しようとしている問題です。

pthread_barrier_t barrier; 

pthread_barrier_init(&barrier, NULL, NUM_THREADS); 

と同期するためにpthread_barrier_wait()を使用します：（あなたのメイン機能では、以前のスレッドを生成する）NUM_THREADSとのバリアを初期化

void *thread_func(void *arg) 
{ 
    while(1) { 
     job1(); 
     pthread_barrier_wait(&barrier); 
     job2(); 
    } 
    return NULL; 
} 

あなたはまた、他のすべてのスレッドまで待機するスレッドが必要な場合再びjob1()に開始することができ、それらのいずれかの前job2()をcompeltedしている、あなたは、バリアの2番目のウェイトを追加することができます。

void *thread_func(void *arg) 
{ 
    while(1) { 
     job1(); 
     pthread_barrier_wait(&barrier); 
     job2(); 
     pthread_barrier_wait(&barrier); 
    } 
    return NULL; 
} 

Answer 2

通常、名前がbarrierである高水準並行制御構造を記述します。 C++標準ライブラリはproposedでしたが、将来はC++標準ライブラリの一部になりますが、バリアの実装はありません。

標準ライブラリが解決策を提供するまでは、もちろんバリアを実装することもできます（条件変数を使用できます）。platform specific threading APIまたはwrapper libraryを使用します。