Communicating between two threads

by

You could have a BlockingQueue of message objects. Other threads would place messages onto the queue. As part of the while(true) loop, thread A would poll the queue and process any messages that have arrived.

In code:

class A extends Thread{
 List<Object>  objs = something ;//init it
 BlockingQueue<Message> queue = new LinkedBlockingQueue<Message>();
 void run(){
     while(true){
       Message msg;
       while ((msg = queue.poll()) != null) {
         // process msg
       }
       // do other stuff
     }
   }
}

Other threads can now call queue.put() to send messages to thread A.

More Related Contents:

  1. How starvation occurs in producer consumer problem
  2. StreamCorruptedException: invalid type code: AC
  3. What is a daemon thread in Java?
  4. Avoid synchronized(this) in Java?
  5. How to wait for all threads to finish, using ExecutorService?
  6. Is there an advantage to use a Synchronized Method instead of a Synchronized Block?
  7. Is multi-thread output from System.out.println interleaved
  8. When and how should I use a ThreadLocal variable?
  9. Running code in main thread from another thread
  10. What is the difference between Thread.start() and Thread.run()?
  11. The difference between the Runnable and Callable interfaces in Java
  12. Why invoke Thread.currentThread.interrupt() in a catch InterruptException block?
  13. Why use a ReentrantLock if one can use synchronized(this)?
  14. Java Wait for thread to finish
  15. How is CountDownLatch used in Java Multithreading?
  16. Is it safe to construct Swing/AWT widgets NOT on the Event Dispatch Thread?
  17. How to terminate a thread blocking on socket IO operation instantly?
  18. Waiting on multiple threads to complete in Java
  19. Java Server with Multiclient communication.
  20. ThreadLocal & Memory Leak
  21. How do I implement task prioritization using an ExecutorService in Java 5?
  22. Program hangs if thread is created in static initializer block
  23. How to interrupt BufferedReader’s readLine
  24. Where to stop/destroy threads in Android Service class?
  25. How pause and then resume a thread?
  26. Why should I use concurrent characteristic in parallel stream with collect?
  27. How to pause/resume all threads in an ExecutorService in Java?
  28. Timer in Java Thread
  29. RestTemplate should be static globally declared?
  30. Multithreading Socket communication Client/Server

Leave a Comment