I know this thread is quite a bit old, but since I came across it sometimes in my searches, I decided to share this producer-consumer code for people wondering how to implement a simple generic producer-consumer job queue. The Job class is used to ‘store’ an object’s method call in the form of a delegate. … Read more
The code is older than that – I wrote it some time before .NET 2.0 came out. The concept of a producer/consumer queue is way older than that though 🙂 Yes, that code is safe as far as I’m aware – but it has some deficiencies: It’s non-generic. A modern version would certainly be generic. … Read more
Java 5+ has all the tools you need for this kind of thing. You will want to: Put all your Producers in one ExecutorService; Put all your Consumers in another ExecutorService; If necessary, communicate between the two using a BlockingQueue. I say “if necessary” for (3) because from my experience it’s an unnecessary step. All … Read more
If correctly coded producer-consumer problem is always going to be starvation free. Consumer blocking till there is ready buffer to consume. Producer blocking till there is empty buffer to produce. Producer after producing immediately moving buffer to ready buffer queue. Consumer after consuming immediately moving buffer to empty buffer queue. This arrangement can not lead … Read more