Programming: Concurrency Patterns: Difference between revisions
From wikinotes
(Created page with " = Producer/Consumer = <blockquote> * A producer adds data to a synchronized queue * A variable number of consumers process data from a synchronized queue in a loop * When producer is finished, send a poison pill for each worker, informing it to break/exit the loop gracefully </blockquote><!-- Producer/Consumer -->") |
|||
| Line 5: | Line 5: | ||
* A variable number of consumers process data from a synchronized queue in a loop | * A variable number of consumers process data from a synchronized queue in a loop | ||
* When producer is finished, send a poison pill for each worker, informing it to break/exit the loop gracefully | * When producer is finished, send a poison pill for each worker, informing it to break/exit the loop gracefully | ||
* Join on worker threads (wait to close) | |||
</blockquote><!-- Producer/Consumer --> | </blockquote><!-- Producer/Consumer --> | ||
Revision as of 21:48, 6 August 2022
Producer/Consumer
- A producer adds data to a synchronized queue
- A variable number of consumers process data from a synchronized queue in a loop
- When producer is finished, send a poison pill for each worker, informing it to break/exit the loop gracefully
- Join on worker threads (wait to close)
