[java] 모든 스레드가 Java에서 작업을 마칠 때까지 기다립니다.

다른 스레드가 작업을 완료 할 때까지 Thread Main을 기다리거나 차단합니다.

말했듯 @Ravindra babu이 다양한 방법으로 달성 할 수 있지만 예를 들어 보여줍니다.

• java.lang.Thread. join () ^{이후 : 1.0}

  public static void joiningThreads() throws InterruptedException {
      Thread t1 = new Thread( new LatchTask(1, null), "T1" );
      Thread t2 = new Thread( new LatchTask(7, null), "T2" );
      Thread t3 = new Thread( new LatchTask(5, null), "T3" );
      Thread t4 = new Thread( new LatchTask(2, null), "T4" );
  
      // Start all the threads
      t1.start();
      t2.start();
      t3.start();
      t4.start();
  
      // Wait till all threads completes
      t1.join();
      t2.join();
      t3.join();
      t4.join();
  }
  

• java.util.concurrent.CountDownLatch ^{이후 : 1.5}

  • .countDown() «래치 그룹의 수를 줄입니다.
  • .await() «await 메서드는 현재 카운트가 0이 될 때까지 차단됩니다.

  생성 latchGroupCount = 4한 경우 countDown()4 번 호출하여 카운트 0을 만들어야합니다. 따라서 await()차단 스레드가 해제됩니다.

  public static void latchThreads() throws InterruptedException {
      int latchGroupCount = 4;
      CountDownLatch latch = new CountDownLatch(latchGroupCount);
      Thread t1 = new Thread( new LatchTask(1, latch), "T1" );
      Thread t2 = new Thread( new LatchTask(7, latch), "T2" );
      Thread t3 = new Thread( new LatchTask(5, latch), "T3" );
      Thread t4 = new Thread( new LatchTask(2, latch), "T4" );
  
      t1.start();
      t2.start();
      t3.start();
      t4.start();
  
      //latch.countDown();
  
      latch.await(); // block until latchGroupCount is 0.
  }
  

Threaded 클래스의 예제 코드 LatchTask. 접근 방식 사용 joiningThreads();
및 latchThreads();주요 방법 을 테스트합니다 .

class LatchTask extends Thread {
    CountDownLatch latch;
    int iterations = 10;
    public LatchTask(int iterations, CountDownLatch latch) {
        this.iterations = iterations;
        this.latch = latch;
    }

    @Override
    public void run() {
        String threadName = Thread.currentThread().getName();
        System.out.println(threadName + " : Started Task...");

        for (int i = 0; i < iterations; i++) {
            System.out.println(threadName + " : " + i);
            MainThread_Wait_TillWorkerThreadsComplete.sleep(1);
        }
        System.out.println(threadName + " : Completed Task");
        // countDown() « Decrements the count of the latch group.
        if(latch != null)
            latch.countDown();
    }
}

• CyclicBarriers 스레드 집합이 서로 공통 장벽 지점에 도달 할 때까지 모두 대기 할 수 있도록하는 동기화 보조 장치 CyclicBarrier 는 때때로 서로를 기다려야하는 고정 된 크기의 스레드 파티를 포함하는 프로그램에서 유용합니다. 장벽은 대기중인 스레드가 해제 된 후 재사용 될 수 있기 때문에 순환이라고합니다.

  CyclicBarrier barrier = new CyclicBarrier(3);
  barrier.await();
  

  예를 들어이 Concurrent_ParallelNotifyies 클래스 를 참조하십시오 .

• 실행기 프레임 워크 : ExecutorService 를 사용하여 스레드 풀을 만들고 Future를 사용하여 비동기 작업의 진행 상황을 추적 할 수 있습니다 .

  • submit(Runnable), submit(Callable)Future Object를 반환합니다. future.get()함수 를 사용 하여 작업 스레드가 작업을 완료 할 때까지 주 스레드를 차단할 수 있습니다.

  • invokeAll(...) -각 Callable의 실행 결과를 얻을 수있는 Future 객체 목록을 반환합니다.

실행자 프레임 워크와 함께 실행 가능한 인터페이스, 호출 가능한 인터페이스를 사용하는 예제 를 찾으십시오 .

@또한보십시오

• 스레드가 아직 살아 있는지 알아 보시겠습니까?