[이펙티브 자바] Item17 완벽공략. CountDownLatch

item17. 변경 가능성을 최소화 하라. 

" p.113 java.util.concurrent 패키지의 CountDownLatch 클래스가 이상의 원칙을 잘 방증한다."

 

 

 

java.util.concurrent 패키지

: 병행(Concurrency) 프로그래밍에 유용하게 사용할 수 있는 유틸리티 묶음 

 

- 병행(Concurrency)와 병렬(Parallelism)의 차이 

병행은 여러 작업을 번갈아 가며 실행해 마치 동시에 여러 작업을 동시에 처리하듯 보이지만, 실제로는 한 번에 오직 한 작업만을 실행한다. (cpu가 한개여도 가능) 

병렬은 여러 작업을 실제로 동시에 처리하는 것으로 cpu가 여러개 있어야 가능하다. 

 

자바의 concurrent 패키지에서는 병행 애플리케이션에 유용한 다양한 툴을 제공한다. 

-> BlockingQueue, Callable, ConcurrentMap, Executor, ExecutorService, Future. ... 

 

 

 

CountDownLatch

: 다른 여러 스레드로 실행하는 여러 오퍼레이션이 마칠 때까지 기다릴 때 사용할 수 있는 유틸리티

CountDownLatch는 스레드 n개를 실행하고 일정 개수의 스레드가 모두 끝날 때 까지 기다려야만 다음으로 진행할 수있거나 다른 스레들를 실행시킬 수 있는 경우에 사용한다. 

 

public class ConcurrentExample
{
   public static void main(String[] args) throws InterruptedException
   {
      int N = 10;
      CountDownLatch startSignal = new CountDownLatch(1);
      CountDownLatch doneSignal = new CountDownLatch(N);
      
      for (int i = 0; i< N; i++) // create and start threads
      {
         new Thread(new Worker(startSignal, doneSignal)).start();
      }
      
      ready(); // don't let run yet
      startSignal.countDown(); // let all threads proceed
      doneSignal.await(); // wait for all to finish
      done();
      
   }
   
   private static void ready()
   {
      System.out.println("ready~~~");
   }
   
   private static void done()
   {
      System.out.println("done~~~");
   }
   
   private static class Worker implements Runnable
   {
      private final CountDownLatch startSignal;
      private final CountDownLatch doneSignal;
      
      public Worker(CountDownLatch startSignal, CountDownLatch doneSignal)
      {
         this.startSignal = startSignal;
         this.doneSignal = doneSignal;
      }
      
      @Override
      public void run()
      {
         try
         {
            doWork();
            doneSignal.countDown();
            startSignal.await();
         }
         catch (InterruptedException e) {
         
         }
      }
      
       void doWork()
      {
         System.out.println("working thread : " + Thread.currentThread().getName());
      }
   }
}

CountDownLatch는 초기화할 때 정수값 count를 넣어주고 스레드는 마지막에 countDown() 메셔드를 불러준다. 

그러면 초기화할 때 넣어준 정수값이 하나 내려가고, 각 스레드는 마지막에 자신이 실행완료했음을 countDown 메서드로 알려준다. 

그리고 이 스레드들이 끝나기를 기다리는 쪽 입장에서는 await() 메서드를 불러준다. 그러면 현재 메서드가 실행중인 메인스레드는 더이상 진행하지 않고 countDownLatch의 count가 0이 될 때까지 기다린다. 

 

 

int N = 10;
CountDownLatch startSignal = new CountDownLatch(1);
CountDownLatch doneSignal = new CountDownLatch(N);

-> 초기화 할 때 숫자를 입력하고,

startSignal.countDown(); // let all threads proceed
doneSignal.await(); // wait for all to finish

await() 메서드를 사용해서 숫자가 0이 될 때까지 기다린다. 그리고 숫자를 셀 때는 countDown() 메서드를 사용한다. 

 

 

countDownLatch는 시작 또는 종료 신호로 사용할 수 있으며, 재사용할 수 있는 인스턴스가 아니기 때문에 숫자를 리셋해서 재사용하려면 CyclicBarrier를 사용해야 한다.