2012-04-19 11 views
-8

は、私がスレッドを開始していると私はこれを解決するいくつかの問題を抱えている:のPthread Cのsyncronization

このプログラムは多数の順序付けられたシーケンスを生成し、2番目のタスクは、それらを読み込み、画面上に表示します。必要に応じてこれを修復するにはどうすればよいですか?

Consumed item: 1 
Consumed item: 2 
Consumed item: 3 
Consumed item: 4 
Consumed item: 5 
Consumed item: 6 

実際の出力:

Consumed item: 1 
Consumed item: 4 
Consumed item: 7 
Consumed item: 10 
Consumed item: 11 
Consumed item: 14 

プログラム:出力期待

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

#define   NBUFFERS  2 

int item, in=0, out=0; 
int buffer[NBUFFERS]; 
int stop =0; 

void *ProducerTask(void *data) //This is the producer task 
{ 
    int nextp = 0; 
    struct timespec mytime; 
    mytime.tv_sec = 0; 
    mytime.tv_nsec = 200000000; 

    while (!stop) { 
      nanosleep(&mytime, NULL); 
      nextp++; 
      buffer[in] = nextp; /* produce a new item */ 
      in = (in + 1) % NBUFFERS; 
    } 
    pthread_exit(0); 
} 

void *ConsumerTask(void *data) 
{ 
    int nextc; 
    struct timespec mytime; 
    mytime.tv_sec = 0; 
    mytime.tv_nsec = 500000000; 

    while (!stop) { 
      nanosleep(&mytime, NULL); 
      nextc = buffer[out]; /* consume a item */ 
      out = (out + 1) % NBUFFERS; 
      printf("Consumed item: %d\n", nextc); 
    } 
    pthread_exit(0); 
} 

void *MonitorTask (void *data) //This is the monitor task 
{ 
    getchar(); 
    stop = 1; 
    pthread_exit(0); 
} 

void main(void) 
{ 
    pthread_t task1; 
    pthread_t task2; 
    pthread_t task3; 

    pthread_create (&task1, NULL, ProducerTask, NULL); 
    pthread_create (&task2, NULL, ConsumerTask, NULL); 
    pthread_create (&task3, NULL, MonitorTask, NULL); 

    pthread_join(task1,NULL); 
    pthread_join(task2,NULL); 
    pthread_join(task3,NULL); 

    printf("Main program exiting.\n"); 
} 
+3

"このプログラムを修正する"は、あなたの問題を説明する良い方法ではありません。良い回答を得るには、問題を正確に特定し、記述する必要があります。 –

+1

期待される結果(または成果)は何ですか?言い換えれば、あなたの問題は何ですか? –

+0

それは変わった! – dani

答えて

3
int buffer[NBUFFERS]; 
int stop =0; 

は、彼らがいずれかを持っていけない、グローバルで複数のスレッドからアクセスされているsynchronization。次の
race condition問題でない場合は問題です。

太字のインラインリンクは、あなたが間違っていることを少なくとも頭打ちにします。

+0

これはおそらく参考になるでしょう: [異なるcファイルのpthreadのグローバル変数へのアクセス](http://stackoverflow.com/questions/7382636/accessing-global-variables-in-pthreads-in-different-c-files) – nacho4d

2

共有リソースは、少なくとも、条件変数によるスレッド通信で解決される必要があります。this example(C++ですが、私の要点を示しています)。

編集:この場合、奇妙な出力は、プロデューサよりも低速のコンシューマと組み合わせて小さなバッファを使用しているためです。