java - Comunicando entre dos hilos

multithreading communicate

Question

Tengo un hilo, A que tiene una lista. Lista contiene algunos objetos. Ahora quiero diseñar un mecanismo por el cual pueda enviar un mensaje a la secuencia A

Thread A ejecuta en un bucle (no espera ni duerme). Algún otro hilo, B , envía algún mensaje al hilo A y el hilo A vacía todas sus colas.

¿Cómo puedo enviar mensajes entre hilos?

class A extends Thread {
    List<Object> objs = something; //Init it
    void run() {
        while(true) {
            //Body which works on objects.
            //After receiving an external message, "A" should perform some action, for example, empty objects.
        }
    }
}

EDITAR: ¿Puedo hacerlo así?

class A extends Thread {
    List<Object> objs = something; //Init it
    Boolean flag = false;

    public void setFlag(boolean value) {
        synchronized(flag) {
            this.flag = value;
        }
    }

    public void getFlag() {
        synchronized(flag) {
            return this.flag;
        }
    }

    void run() {
        while(true) {
            //Body which works on objects.
            //After receiving an external message, A should perform some action, for example, empty objects.
            if (getFlag == true)
                //Empty list
        }
    }
}

Answer 1

Debería poder agregar un método a la clase "A" que pueda llamarse en cualquier parte de su código. Simplemente mantenga la referencia a su instancia de clase "A" en un lugar accesible.

class A extends Thread{
 List<Object>  objs = something ;//init it
 void run(){
   while(true){
       //body which works on objs
       //open receiving external message A should perform some action ie empty objs
     }
   }
  void ChangeState()
  {
     //clear objs
  } 
}

Answer 2

En un caso simplista, puede agregar alguna variable de instancia a la clase A del hilo y hacer que el hilo B establezca su valor para indicar que el hilo A debe borrar sus colas. En un caso más avanzado, puede utilizar una cola de mensajes a la que pueden acceder ambos subprocesos A y B. B colocaría un mensaje allí y A leería y actuaría sobre él.

En todos los casos, el acceso a la variable o la cola debe estar debidamente protegido para el acceso de múltiples subprocesos.

Answer 3

Podrías tener un BlockingQueue de objetos de mensaje. Otros hilos pondrían mensajes en la cola. Como parte del bucle while(true) , el hilo A poll la cola y procesaría cualquier mensaje que haya llegado.

En codigo:

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
     }
   }
}

Otros subprocesos ahora pueden llamar a queue.put() para enviar mensajes al subproceso A