[java] 다른 스레드가 완료되었는지 확인하는 방법은 무엇입니까?

이를 수행 할 수있는 여러 가지 방법이 있습니다.

1. 사용 를 Thread.join () 주 스레드에서 각 스레드가 완료 될 때까지 차단 방식으로 기다리거나하는
2. 각 스레드가 완료 될 때까지 기다리려면 폴링 방식으로 Thread.isAlive () 를 확인하십시오 ( 일반적으로 권장하지 않음).
3. Unorthodox는 문제의 각 스레드에 대해 setUncaughtExceptionHandler 를 호출하여 객체의 메소드를 호출하고 각 스레드가 완료 될 때 포착되지 않은 예외를 처리하도록 프로그래밍합니다.
4. 에서 잠금 또는 싱크로 나이저 또는 메커니즘을 사용 하고있는 java.util.concurrent , 또는
5. 더 많은 정통, 기본 스레드에서 리스너를 만든 다음 각 스레드를 프로그래밍하여 리스너에게 완료되었음을 알리십시오.

아이디어 # 5를 구현하는 방법? 한 가지 방법은 먼저 인터페이스를 만드는 것입니다.

public interface ThreadCompleteListener {
    void notifyOfThreadComplete(final Thread thread);
}

그런 다음 다음 클래스를 만듭니다.

public abstract class NotifyingThread extends Thread {
  private final Set<ThreadCompleteListener> listeners
                   = new CopyOnWriteArraySet<ThreadCompleteListener>();
  public final void addListener(final ThreadCompleteListener listener) {
    listeners.add(listener);
  }
  public final void removeListener(final ThreadCompleteListener listener) {
    listeners.remove(listener);
  }
  private final void notifyListeners() {
    for (ThreadCompleteListener listener : listeners) {
      listener.notifyOfThreadComplete(this);
    }
  }
  @Override
  public final void run() {
    try {
      doRun();
    } finally {
      notifyListeners();
    }
  }
  public abstract void doRun();
}

그런 다음 각 스레드가 확장 NotifyingThread되고 구현 run()하는 대신 구현 doRun()됩니다. 따라서 완료되면 알림을 기다리는 사람에게 자동으로 알립니다.

마지막으로, 모든 스레드를 시작하는 클래스 (또는 적어도 알림을 기다리는 객체)의 기본 클래스에서 implement ThreadCompleteListener각 스레드를 생성 한 직후와 즉시 해당 클래스를 리스너 목록에 추가하십시오.

NotifyingThread thread1 = new OneOfYourThreads();
thread1.addListener(this); // add ourselves as a listener
thread1.start();           // Start the Thread

그런 다음 각 스레드가 종료되면 notifyOfThreadComplete방금 완료되었거나 충돌 한 Thread 인스턴스와 함께 메서드가 호출됩니다.

더 잘 참고하는 것 implements Runnable보다는 extends Thread위한 NotifyingThread스레드를 확장하는 것은 일반적으로 새로운 코드에 낙심 될 때. 그러나 나는 당신의 질문에 코딩하고 있습니다. NotifyingThread구현 하도록 클래스를 변경하면 Runnable스레드를 관리하는 코드 중 일부를 변경해야합니다. 이는 매우 간단합니다.

답변

public class Downloader {
  private CyclicBarrier barrier;
  private final static int NUMBER_OF_DOWNLOADING_THREADS;

  private DownloadingThread extends Thread {
    private final String url;
    public DownloadingThread(String url) {
      super();
      this.url = url;
    }
    @Override
    public void run() {
      barrier.await(); // label1
      download(url);
      barrier.await(); // label2
    }
  }
  public void startDownload() {
    // plus one for the main thread of execution
    barrier = new CyclicBarrier(NUMBER_OF_DOWNLOADING_THREADS + 1); // label0
    for (int i = 0; i < NUMBER_OF_DOWNLOADING_THREADS; i++) {
      new DownloadingThread("http://www.flickr.com/someUser/pic" + i + ".jpg").start();
    }
    barrier.await(); // label3
    displayMessage("Please wait...");
    barrier.await(); // label4
    displayMessage("Finished");
  }
}

public interface CallbackRunnable extends Runnable {
    public void callback();
}

public class CallbackExecutor implements Executor {

    @Override
    public void execute(final Runnable r) {
        final Thread runner = new Thread(r);
        runner.start();
        if ( r instanceof CallbackRunnable ) {
            // create a thread to perform the callback
            Thread callerbacker = new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        // block until the running thread is done
                        runner.join();
                        ((CallbackRunnable)r).callback();
                    }
                    catch ( InterruptedException e ) {
                        // someone doesn't want us running. ok, maybe we give up.
                    }
                }
            });
            callerbacker.start();
        }
    }

}

*  NEW
  A thread that has not yet started is in this state.
* RUNNABLE
  A thread executing in the Java virtual machine is in this state.
* BLOCKED
  A thread that is blocked waiting for a monitor lock is in this state.
* WAITING
  A thread that is waiting indefinitely for another thread to perform a particular action is in this state.
* TIMED_WAITING
  A thread that is waiting for another thread to perform an action for up to a specified waiting time is in this state.
* TERMINATED
  A thread that has exited is in this state.