티스토리 뷰
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.
'개발 관련 > Java' 카테고리의 다른 글
JAVA 텍스트 파일의 Encoding 정보 가져오기 + String Encoding 변환하기. (1) | 2015.11.18 |
---|---|
Guava 사용 요약 슬라이드. (0) | 2015.04.17 |
[JAVA:병렬 프로그래밍 - 3] Exchanger 사용하기. (0) | 2014.10.06 |
[JAVA:병렬 프로그래밍 - 1] CountDownLatch 사용하기. (0) | 2014.08.19 |
[JAVA] int 또는 float 를 byte 배열 타입으로 변환. byte 배열을 int 또는 float 으로 변환, Unsigned 표현. (1) | 2014.03.04 |
- Total
- Today
- Yesterday
- WS2812B
- 병렬 프로그래밍
- 침블락
- 칩두이노
- 개발
- 부트로더
- 아두이노
- activity
- arduino
- Android
- Java
- ndk
- 안드로이드 개발
- Cheapduino
- ENC28J60
- 안드로이드
- json
- NeoPixel
- Iot
- 블루투스
- HC-06
- noidemcu
- oled
- ESP8266
- 가습기
- 이더넷
- 스마트 무드등
- bluetooth
- ATtiny85
- 알리익스프레스
일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | ||
6 | 7 | 8 | 9 | 10 | 11 | 12 |
13 | 14 | 15 | 16 | 17 | 18 | 19 |
20 | 21 | 22 | 23 | 24 | 25 | 26 |
27 | 28 | 29 | 30 | 31 |