Producer/Consumer threads using a Queue

by

Java 5+ has all the tools you need for this kind of thing. You will want to:

  1. Put all your Producers in one ExecutorService;
  2. Put all your Consumers in another ExecutorService;
  3. 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 you do is submit new tasks to the consumer executor service. So:

final ExecutorService producers = Executors.newFixedThreadPool(100);
final ExecutorService consumers = Executors.newFixedThreadPool(100);
while (/* has more work */) {
  producers.submit(...);
}
producers.shutdown();
producers.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
consumers.shutdown();
consumers.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);

So the producers submit directly to consumers.

More Related Contents:

  1. How starvation occurs in producer consumer problem
  2. Which concurrent Queue implementation should I use in Java?
  3. LinkedBlockingQueue vs ConcurrentLinkedQueue
  4. What’s the difference between Thread start() and Runnable run()
  5. Difference between volatile and synchronized in Java
  6. In ArrayBlockingQueue, why copy final member field into local final variable?
  7. How many threads can a Java VM support?
  8. using sleep() for a single thread
  9. How does synchronized work in Java
  10. How could I add a simple delay in a Java Swing application?
  11. What does this thread join code mean?
  12. What are the advantages of using an ExecutorService?
  13. Is ExecutorService (specifically ThreadPoolExecutor) thread safe?
  14. Forcing multiple threads to use multiple CPUs when they are available
  15. Background Thread for a Tomcat servlet app [duplicate]
  16. ThreadPoolExecutor Block When Queue Is Full?
  17. Should you synchronize the run method? Why or why not?
  18. Why does Java not see the updated value from another thread?
  19. What is adaptive spinning w.r.t lock acquisition?
  20. Why is Swing threading model considered wrong and how should it be? [closed]
  21. Testing initialization safety of final fields
  22. How can I wrap a method so that I can kill its execution if it exceeds a specified timeout?
  23. Thread safe Hash Map?
  24. Java multithreading – thread priority
  25. How to listen for Firebase setValue completion
  26. Static variables and multithreading in java
  27. who and when notify the thread.wait() when thread.join() is called?
  28. Dynamic Thread Pool
  29. JAVAFX : why wait cursor needs a new thread?
  30. Concurrent read/write of named pipe in Java (on windows)

Leave a Comment