Producer Consumer Pattern - With Java Example

[@1056AD]

Gets used everywhere in the industry .. such a simple concept yet an indispensable one. Thanks for picking it up

[@JakobJenkov]

You are welcome :-) ... and I agree, it's a very useful pattern know and be able to recognize!

[@singhvertika8167]

Thanks Jakob for this video that just made these complex concepts so much easier for us to understand

[@JakobJenkov]

You are welcome ! ... Great to hear!

[@contactdi8426]

Thanks a ton Jakon for such a useful and awesome series! You are such a awesome teacher.

[@JakobJenkov]

Thank you for your kind words !

[@seydaozdemir]

Thank you Jacob. This series about Threads well explained.

[@JakobJenkov]

You are welcome! :-) ... glad you find it useful!

[@vikassharma2662]

Good video with detailed explanation , keep up the work jakob

[@JakobJenkov]

Thanks :-)

[@jakhongirrasulov2329]

Thank you so much. I've been learning a lot from you.

[@JakobJenkov]

That is great to hear ! Then my efforts are not completely wasted :-)

[@vilastadoori]

This is awesome Jenkov . God bless you!!

[@JakobJenkov]

Thank you ! I am glad you found it useful! :-)

[@mostinho7]

Thank you great video

[@JakobJenkov]

You are welcome :-)

[@kafychannel]

great tutorials thanks !

[@JakobJenkov]

You are welcome :-)

[@nirmalgurjar8181]

Is blockingQueue thread safe or synchronized or safe to use without volatile or locking mechanism ?

[@JakobJenkov]

BlockingQueue is ThreadSafe, yes.

[@quantum598]

Jakob the videos are brilliant, I have a question as I was trying to tackle this on my own...say we have 3 threads (0,1,2) and we want thread 0 to msg all threads (1 and 2) and then we have thread 1 doing the same with threads 0 and 2...and so forth, how do we go about that? I know its kind of similar to the producer/consumer example but in this case each thread can produce/consume messages as they arrive? curious to know as I have found few resources on Stack as well as here :/

[@JakobJenkov]

One way to solve this problem would be to give each thread an inbound queue (BlockingQueue) via which they can be messaged. Thread 1 can then send messages (objects) to the queues of thread 2 and thread 3, and thread 2 can write to the queues of thread 1 and thread 3 etc.

[@h.psrivastav9205]

import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; public class Main { private static final int NUM_THREADS = 3; private static final BlockingQueue[] queues = new BlockingQueue[NUM_THREADS]; public static void main(String[] args) { for (int i = 0; i < NUM_THREADS; i++) { queues[i] = new LinkedBlockingQueue(); } for (int i = 0; i < NUM_THREADS; i++) { final int threadId = i; Thread thread = new Thread(() -> threadFunc(threadId)); thread.start(); } } private static void threadFunc(int threadId) { while (true) { // Check for messages while (!queues[threadId].isEmpty()) { String msg = queues[threadId].poll(); System.out.println("Thread " + threadId + " received: " + msg); } // Send messages to other threads for (int i = 0; i < NUM_THREADS; i++) { if (i != threadId) { queues[i].offer("Hello from thread " + threadId); } } } } }

[@fabricioaraujo7642]

thanks Jakob :)

[@JakobJenkov]

You are welcome :-)

[@alexandrufilipescu1301]

Hello, I was wondering why the consumer threads are alternating? What makes them follow that behaviour? Thank you!

[@JakobJenkov]

The threads run at the same time. They will most likely not be perfectly alternating - only interleaving at a semi-random order.

[@alexandrufilipescu1301]

@@JakobJenkov Thank you for explaining the mechanism!!

[@mohamedazizlakhal9368]

Thanks a lot!

[@JakobJenkov]

Thank you! And you are welcome! :-)

[@sectorseven4771]

How would one retrieve and merge the results of the consumers once finished? Let's say a user (could be many users) clicks a button and produces many tasks to do like query a website and retrieve information that needs to be merged/summed up when all tasks for that user have been consumed. I am currently testing a multi user & threading environment with a custom thread pool, but this thread pool is working in a 'first come first serve' manner that is not very performant to say the least and I thought to give the consumer producer pattern a try, but I do not know if this is the correct approach. Would highly appreciate some advice from your side.

[@JakobJenkov]

There is possible also the ForkAndJoinPool in Java. jenkov.com/tutorials/java-util-concurrent/java-fork-and-join-forkjoinpool.html

[@rinkutekchandani7978]

Thanks Jacob for the video. I have a question,if we want to consume messages in the order they were produced using two consumers,how could we do that

[@JakobJenkov]

Well, the two consumers would have to take messages from the same queue - so the queue keeps the sequence of the messages. However, there is no way to guarantee which of the threads finishes their tasks first. If Thread A and Thread B both take a task right after each other from the queue, even if Thread B took its task after Thread A, it might still finish it before Thread A finishes its task. If you want to guarantee that something post-processing happens in a certain order, you will need to implement that yourself.

[@bbc168able]

Thanks, great videos. apologies for clicking on dislike accidentally instead of like, don't know how to revert.

[@JakobJenkov]

Thanks - you just click the dislike button one more time, then you revert it.

[@quangtuan202]

Can you please add more videos from basic to advanced level?

[@JakobJenkov]

What exactly do you mean with "from basic to advanced level" ?

[@PaulO-ym5dm]

goat

[@JakobJenkov]

goat?

[@Karupin-and-chill]

@@JakobJenkov it means greatest of all time