生産者-消費者問題 とは？

容量に限りのある回転寿司のレーンを想像してみて。板前さんが寿司を置き、お客さんが取る。満杯なら置く側、空なら取る側が待つ、といった調整が必要だよ。プログラムでは共有バッファへの追加と取り出しを、競合なく行うことも考えるんだ。

たとえば処理依頼をキューへ入れるスレッドと、それを取り出すワーカースレッドを分ける場面だよ。JavaのBlockingQueueにも複数の生産者と消費者の例がある。Webサーバーやログ処理も、そうした構成で設計できるんだ。

一つの方法は、空き数とデータ数を数えるセマフォに、共有状態を守るロックを組み合わせることだよ。空きやデータを待ってからロックを取る順序が大切。相手が必要とするロックを持ったまま待つと、互いに進めなくなることがあるんだ。

Pythonのqueue.QueueやJavaのBlockingQueueなど、同期を内部で扱うキューを使えるよ。ただし操作によって動作は異なる。たとえばJavaのput/takeは必要なら待ち、offer/pollには待たずに失敗を返す形や、時間を区切って待つ形があるんだ。

容量と操作の選び方によるよ。PythonのQueueも、待つ操作のほかに満杯や空を例外で知らせる操作がある。容量を制限しないキューもあるけれど、処理が追いつかなければデータがたまり続ける。満杯時の扱いはシステムの要件に合わせるんだ。

共通の目安としては決められないよ。データ一件の大きさ、到着の集中、処理速度、許容する待ち時間などによって変わる。容量を増やしても、消費側が継続的に追いつかない問題自体は解消しないので、負荷を測って調整するんだ。