次のコードは、ウィキペディアから取得したものです。
semaphore mutex = 1;
semaphore fillCount = 0;
semaphore emptyCount = BUFFER_SIZE;
procedure producer() {
while (true) {
item = produceItem();
down(emptyCount);
down(mutex);
putItemIntoBuffer(item);
up(mutex);
up(fillCount);
}
}
procedure consumer() {
while (true) {
down(fillCount);
down(mutex);
item = removeItemFromBuffer();
up(mutex);
up(emptyCount);
consumeItem(item);
}
}
私が混乱しているのは、消費者と生産者の down/up(fillCount) がミューテックスの外にある理由です。それは、同時に複数のスレッドによって変更される可能性があるということではないでしょうか?