CountDownLatch

멀티의 쓰레드가 다 종료될 때까지 기다리는 로직을 구현할 경우 유용한 CountDownLatch 클래스의 사용 예,.

package sample.thread;

import java.util.Random;

import java.util.concurrent.CountDownLatch;

public class CountDownLatchSample {

private final static int THREAD_COUNT = 10;

private static CountDownLatch lacth = new CountDownLatch(THREAD_COUNT);

public static class RandomSleepRunnable implements Runnable {

private int id = 0;

private static Random random = new Random(System.currentTimeMillis());

public RandomSleepRunnable(int id) {

this.id = id;

}

@Override public void run() { 

System.out.println("Thread(" + id + ") : Start."); // 1000ms 에서 2000ms 사이의 딜레이 값을 랜덤하게 생성. 

int delay = random.nextInt(1001) + 1000; 

try { 

System.out.println("Thread(" + id + ") : Sleep " + delay + "ms"); 

Thread.sleep(delay); 

} catch (InterruptedException e) { 

e.printStackTrace(); 

} 

System.out.println("Thread(" + id + ") : End."); // lacth 의 카운터에서 -1. 

lacth.countDown(); 

} 

} 

public static void main(String[] args) { 

// 쓰레드를 10개 생성. 

for(int i = 0; i < THREAD_COUNT; ++i) { 

new Thread(new RandomSleepRunnable(i)).start(); 

} 

try { 

// lacth 의 카운트가 0이 될 때 까지 대기한다. 

lacth.await(); 

// 아래와 같이 TimeOut 을 설정할 수 있다. 

// 아래의 경우는, 만약 2000ms 동안 latch 의 카운트가 0 되지 않는다면 

// wait 상태를 해제하고 다음 동작으로 넘어간다. 

//lacth.await(2000, TimeUnit.MILLISECONDS); 

} catch (InterruptedException e) { 

e.printStackTrace(); 

} 

System.out.println("All threads terminated."); 

}

}