Как уведомить ожидающий поток без приостановки основного?

Question

Хотелось бы, чтобы мой основной поток уведомил другую тему о данном событии, но не остановился. Другой поток - это бесконечный цикл, и мне нужно, чтобы он ждал после каждой итерации, пока основной поток не просыпает его снова.

Это, кажется, исключает шаблон wait/notify, поскольку он приостанавливает поток, который вызывает уведомления на общем мониторе. Я также подумал о CyclicBarrier, но я не хочу, чтобы основной поток вызывал Barrier.await, и ждать, пока другая нить не вызовет Barrier.await, потому что это может занять много времени ...

Любая идея? Благодаря !

Answer 1

сделать ожидающий поток, как это:

class MyThread extends Thread() { 
private volatile boolean go; 

public void wakeUpBuddy() { 
    go=true; 
    synchronized(this) { 
     notify(); 
    } 
} 

public void run() { 

    while(!interrupted()) { 
    // some work before wait 

    synchronized(this) { 
     while(!go) { 
     wait(); 
     } 
     go = false; 
    } 

    // some work after release 
    } 
} 


} 

Тогда из основного вызова резьбы на экземпляре MyThread.wakeUpBuddy(); и он пройдет один проход и ждет другого вызова.

Answer 2

Как насчет использования шаблона наблюдателя?

import java.util.Observable; 
import java.util.Observer; 
import java.util.concurrent.TimeUnit; 

public class Main extends Observable { 

    public static void main(String... args) { 

     final MyThread t = new MyThread(); 

     final Main m = new Main(); 
     m.addObserver(t); 

     // start the thread 
     t.start(); 

     for (int i = 0; i < 25; i++) { 
      if (i % 5 == 0) { // event received? 
       m.setChanged(); 
       m.notifyObservers(i); 
      } 

      try { 
       Thread.sleep(TimeUnit.SECONDS.toMillis(1)); 
      } catch (Exception ex) { 

      } 
     } 

    } 

} 

class MyThread extends Thread implements Observer { 

    private boolean wait = true; 

    @Override 
    public void run() { 

     while (true) { 

      while (wait) { 
       try { 
        Thread.sleep(TimeUnit.SECONDS.toMillis(1)); 
       } catch (InterruptedException ex) { 
        // interrupted 
       } 
      } 

      System.out.println("I am invoked .."); 
      wait = true; 
     } 

    } 

    @Override 
    public void update(Observable o, Object arg) { 
     System.out.println("Update received .. " + arg); 
     wait = false; 
    } 

}