Как уведомить всех наблюдателей, не удерживая нить?

Question

У меня есть поток внутри класса, как this-

import java.util.Observable; 

public class Download extends Observable { 

    private int state = 0; 
    private final Thread myThread = new Thread(() -> { 
     /* 
     some work to do here 
     */ 
     setChanged(); 
     notifyObservers(state); 
    }); 

    public void download(int state) { 
     if (!myThread.isAlive()) { 
      this.state = state; 
      myThread.start(); 
     } 
    } 

    public Thread getThread() { 
     return myThread; 
    } 

    public static void MyMethod() throws InterruptedException { 
     Download down = new Download(); 
     down.addObserver((Observable ob, Object dat) -> { 
      System.out.println(ob); 
      if ((int) dat == 1) { 
       down.download(2); 
      } else { 
       System.out.println("success"); 
      } 
     }); 
     down.download(1); 
     down.getThread().join(); 
    } 

    public static void main() throws InterruptedException { 
     MyMethod(); 
    } 
} 

Проблема в том, я никогда не получить его, чтобы напечатать "success" сообщений.

Я предполагаю, что все наблюдатели уведомляются изнутри MyThread. Поэтому, когда down.download(2) вызывается из наблюдателя внутри MyMethod(), предыдущий поток все еще работает и вызов игнорируется.

Как я могу уведомить всех наблюдателей из основного потока, а не из myThread?

Answer 1

Вы звоните down.download(2) в пределах исполнения MyThread, поэтому поток все еще жив, что означает, что ваш метод загрузки ничего не делает из-за if(!myThread.isAlive()).

Я рекомендую вам использовать Executor framework и Listenable Futures from Guava вместо создания потоков вручную. Пример код из вики Гуавы:

ListeningExecutorService service = 
    MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10)); 
ListenableFuture<Explosion> explosion = service.submit(new Callable<Explosion>() { 
    public Explosion call() { 
    return pushBigRedButton(); 
    } 
}); 
Futures.addCallback(explosion, new FutureCallback<Explosion>() { 
    // we want this handler to run immediately after we push the big red button! 
    public void onSuccess(Explosion explosion) { 
    walkAwayFrom(explosion); 
    } 
    public void onFailure(Throwable thrown) { 
    battleArchNemesis(); // escaped the explosion! 
    } 
}); 

Futures.addCallback(..) Обратите внимание, что также имеет перегрузку, которая позволяет определить, какой исполнитель должен выполнить обратный вызов, это, кажется, что вы хотите.