0

Cで複数の生産者/消費者問題を試みていますが、期待どおりに機能していません。以下は、私の実装を表すためのいくつかの擬似コードです。

Thread thread1;
Thread thread2;
Thread thread3;

Data data1;
Mutex data1_mutex;
Semaphore data1_empty;
Semaphore data1_fill;

Data data2;
Mutex data2_mutex;
Semaphore data2_empty;
Semaphore data2_fill;

thread1()
{
   // creates data and places it into data1.

   wait(data1_empty);
   lock(data1_mutex);

   // critical section

   unlock(data1_mutex);
   post(data1_fill);
}

thread2()
{
   // Removes data from data1, processes it, and places it into data2.

   // data1
   wait(data1_fill);
   lock(data1_mutex);

   // data2
   wait(data2_empty);
   lock(data2_mutex);

   // critical section

   // data2
   unlock(data2_mutex);
   post(data2_fill);

   // data1
   unlock(data1_mutex);
   post(data1_empty);
}

thread3()
{
   // Removes data from data2, prints its results, and removes it.

   wait(data2_fill);
   lock(data2_mutex);

   // critical section

   unlock(data2_mutex);
   post(data2_empty);
}

ただし、このソリューションではdata1がいっぱいになりますが、thread2はロックされ、実行されません。私の実装に何か問題がありますか？

編集＃1

私が見つけた問題の1つは、2番目のミューテックスが正しく作成されていなかったことです。何が問題なのかわからないので、すべてのスレッドに最初のミューテックスを使用しています。それを機能させるために私が行った他のこともあるので、後でこれを反映するように擬似コードを更新します。

4

3 に答える 3

1

にある種のキュー タイプを使用する場合、各キューの深さが厳密に 0 または 1 でDataあるという条件を課そうとしない限り、「空の」セマフォを完全に削除できるはずです。 でローカル変数を使用する場合、クリティカル セクションのサイズを小さくすることができます。Datathread2

コードは次のようになります。

thread1() {
    //Wait for data to put in the queue (i.e. a blocking socket read)
    lock(data1_mutex);
    data1.push(someData);
    unlock(data1_mutex);
    post(data1_fill);
}

thread2() {
    DataType dataElement;
    wait(data1_fill);
    lock(data1_mutex);
    dataElement = data1.pop();
    unlock(data1_mutex);

    lock(data2_mutex);
    data2.push(dataElement);
    unlock(data2_mutex);
    post(data2_fill);
}

thread3() {
    DataType dataElement;
    wait(data2_fill);
    lock(data2_mutex);
    dataElement = data2.pop();
    unlock(data2_mutex);
    //do something with dataElement here
}
于 2009-12-02T18:54:37.907 に答える
0

必ず最初に投稿data1_emptyしてください。data2_empty

于 2009-09-10T23:15:41.443 に答える
0

wrang-wrangが言ったこと、およびdata_2_emptyを待っている間、data_1のロックを保持しないようにしてください。スワップアウトする data_1 と data_2 の代替バッファーを保持することで、これを実現できます。Thread_2 は data_1 を処理中に data_2 にスワップし、thread_3 は data_2 を処理中にスワップアウトします。現在の疑似コードでは、スレッド 1 とスレッド 3 を同時に実行できますが、スレッド 2 を他のスレッドと同時に実行することはできません。

于 2009-09-11T00:02:18.293 に答える