CyclicBarrier 를 사용하면 동시에 실행되는 쓰레드 내부 원하는 지점에서 대기를 걸어주고 모든 쓰레드가 대기 상태에 들어갔을때, 대기를 풀어주는 동작을 할 수 있다. 

    예를들어 설명하면 N 개의 쓰레드가 돌고 있다고 가정하고 CyclicBarrier 를 생성할 때 인자값으로 N 을 준다. 각각의 쓰레드 내에서 CyclicBarrier 의 await() 를 호출하고 호출 횟수가 N번에 도달했을 때, N개의 모든 쓰레드의 대기 상태가 해제된다.   


   아래 그림 참고. 설명이 조금 애매한데, 그냥 대충 보고 눈치것 이해하는 것이 좋다. 

   





CyclicBarrier를 활용한 예제코드:

public class main { private final static int THREADS = 5; private static CyclicBarrier cyclicBarrier = new CyclicBarrier(THREADS); 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); System.out.println("Thread(" + id + ") : End Sleep"); } catch (InterruptedException e) { e.printStackTrace(); } try { // 대기. cyclicBarrier 를 생성할 때, 인자값으로 준 count 개수만큼 // await를 호출한다면 모든 쓰레드의 wait 상태가 종료된다. cyclicBarrier.await(); } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } System.out.println("Thread(" + id + ") : End."); } } public static void main(String[] args) { // 쓰레드를 10개 생성. for(int i = 0; i < THREADS; ++i) { new Thread(new RandomSleepRunnable(i)).start(); } } }



결과:

Thread(0) : Start.
Thread(2) : Start.
Thread(2) : Sleep 1128ms
Thread(0) : Sleep 1205ms
Thread(1) : Start.
Thread(1) : Sleep 1968ms
Thread(4) : Start.
Thread(3) : Start.
Thread(4) : Sleep 1834ms
Thread(3) : Sleep 1020ms
Thread(3) : End Sleep
Thread(2) : End Sleep
Thread(0) : End Sleep
Thread(4) : End Sleep
Thread(1) : End Sleep
Thread(1) : End.
Thread(3) : End.
Thread(4) : End.
Thread(0) : End.
Thread(2) : End.


Posted by 범 범2

댓글을 달아 주세요