java.util.concurrent
클래스 CountDownLatch

java.lang.Object 
  java.util.concurrent.CountDownLatch

public class CountDownLatch
extends Object 

다른 thread로 실행중의 조작 세트가 완료할 때까지, 1개 이상의 thread를 대기 가능하게 하는 동기 지원.

CountDownLatch는 지정된 「카운트」를 사용해 초기화됩니다. await 메서드는 countDown() 메서드 호출의 결과로서, 현재의 카운트가 제로에 이를 때까지 블록 합니다. 그 후, 대기중의 thread가 모두 해방되어 후속의 await 호출이 모두 리턴됩니다 . 이것은 단발적인 현상이며, 카운트를 리셋 할 수 없습니다. 카운트를 리셋 하는 버전이 필요한 경우는 CyclicBarrier 사용을 고려해 주세요.

CountDownLatch는 다양한 목적으로 사용 가능한 유연성의 높은 동기 툴입니다. 카운트 1 으로 초기화된 CountDownLatch는 단순한 온/오프의 빗장 또는 게이트로서 기능합니다. await를 호출하는 thread는 모두, countDown()를 호출하는 thread에 의해 오픈될 때까지 게이트로 대기합니다. N에 초기화된 CountDownLatch를 사용하면, N개의 thread가 액션을 완료하는지, 액션이 N 회완료할 때까지, 어느 thread를 대기시킬 수가 있습니다.

CountDownLatch 프로퍼티로 유용한 것은, countDown를 호출하는 thread가 카운트가 제로에 이를 때까지 처리를 대기할 필요가 없는 것입니다. 이것은 모든 thread가 패스할 때까지, 어느 thread도 await를 빠지지 않게 할 뿐입니다.

사용예: 이하에 나타내는 클래스의 페어에서는 워크스 레드의 그룹이 다음의 2개의 카운트다운 빗장을 사용합니다.

• 최초의 클래스는 드라이버의 진행 준비를 할 수 있을 때까지, 워카가 먼저 진행되는 것을 막는 개시 신호이다
• 2번째의 클래스는 모든 워카가 완료할 때까지 드라이버의 대기를 허가하는 완료 신호이다

class Driver { // ...
void main() throws InterruptedException {
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();

doSomethingElse();            // don't let run yet
startSignal.countDown();      // let all threads proceed
doSomethingElse();
doneSignal.await();           // wait for all to finish
}
}

class Worker implements Runnable {
private final CountDownLatch startSignal;
private final CountDownLatch doneSignal;
Worker(CountDownLatch startSignal, CountDownLatch doneSignal) {
this.startSignal = startSignal;
this.doneSignal = doneSignal;
}
public void run() {
try {
startSignal.await();
doWork();
doneSignal.countDown();
} catch (InterruptedException ex) {} // return;
}

void doWork() { ... }
}

이제(이미 ) 1개의 표준적인 사용법은 문제를 N개의 부분에 분할해, 각부를 실행해 빗장을 카운트다운 하는 Runnable를 사용해 각 부분을 기술해, 모든 Runnable를 Executor 큐에 넣는 방법입니다. 하위 부분이 모두 완료하면, 조정역의 thread는 await를 빠질 수가 있습니다. 이 방법으로 thread가 카운트다운을 반복해 실행할 필요가 있는 경우는 대신에 CyclicBarrier를 사용해 주세요.

class Driver2 { // ...
void main() throws InterruptedException {
CountDownLatch doneSignal = new CountDownLatch(N);
Executor e = ...

for (int i = 0; i < N; ++i) // create and start threads
e.execute(new WorkerRunnable(doneSignal, i));

doneSignal.await();           // wait for all to finish
}
}

class WorkerRunnable implements Runnable {
private final CountDownLatch doneSignal;
private final int i;
WorkerRunnable(CountDownLatch doneSignal, int i) {
this.doneSignal = doneSignal;
this.i = i;
}
public void run() {
try {
doWork(i);
doneSignal.countDown();
} catch (InterruptedException ex) {} // return;
}

void doWork() { ... }
}

도입된 버전 :

1.5

생성자 개요

CountDownLatch (int count)
지정된 카운트로 초기화된 CountDownLatch를 구축합니다.

메서드 개요

void	await () thread로인터럽트가 발생하지 않는 한, 빗장의 카운트다운이 제로가 될 때까지 현재의 thread를 대기시킵니다.
boolean	await (long timeout, TimeUnit unit) thread로인터럽트가 발생하는지, 지정된 대기 시간이 경과하지 않는 한, 빗장의 카운트다운이 제로가 될 때까지 현재의 thread를 대기시킵니다.
void	countDown () 빗장의 카운트를 감산해, 카운트가 제로에 이르면 대기중의 thread를 모두 해방합니다.
long	getCount () 현재의 카운트를 리턴합니다.
String	toString () 이 빗장 및 그 상태를 식별하는 캐릭터 라인을 리턴합니다.

클래스 java.lang. Object 로부터 상속된 메서드

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

생성자 상세

CountDownLatch

public CountDownLatch(int count)

지정된 카운트로 초기화된 CountDownLatch를 구축합니다.

파라미터:

count - thread가 await()를 빠지기 전에 countDown()를 호출하는 회수

예외:

IllegalArgumentException - count가 0 보다 작은 경우

메서드의 상세

await

public void await()
           throws InterruptedException 

thread로인터럽트가 발생하지 않는 한, 빗장의 카운트다운이 제로가 될 때까지 현재의 thread를 대기시킵니다.

현재의 카운트가 제로의 경우, 이 메서드는 즉시 복귀합니다.

현재의 카운트가 제로보다 큰 경우, 현재의 thread는 thread의 스케줄링에 대해서는 무효로 여겨져 다음의 2개의 어느 쪽인지가 발생할 때까지 대기합니다.

• countDown() 메서드의 호출에의해 카운트가 제로에 이른다
• 다른 thread가 현재의 thread에인터럽트를 실시한다

현재의 thread가

• 이 메서드에의 엔트리상에서 설정된 인터럽트 스테이터스를 보관 유지하는지,
• 대기중에인터럽트가 발생했을 경우,

InterruptedException이 Throw 되어 현재의 thread의 인터럽트 스테이터스가 클리어 됩니다.

예외:

InterruptedException - 대기중에 현재의 thread로 인터럽트가 발생했을 경우

await

public boolean await(long timeout,
                     TimeUnit  unit)
              throws InterruptedException 

thread로인터럽트가 발생하는지, 지정된 대기 시간이 경과하지 않는 한, 빗장의 카운트다운이 제로가 될 때까지 현재의 thread를 대기시킵니다.

현재의 카운트가 제로의 경우, 이 메서드는 즉시 값 true로 복귀합니다.

현재의 카운트가 제로보다 큰 경우, 현재의 thread는 thread의 스케줄링에 대해서는 무효로 여겨져 다음의 3 개중 한쪽이 발생할 때까지 대기합니다.

• countDown() 메서드의 호출에의해 카운트가 제로에 이르는지,
• 다른 thread가 현재의 thread에인터럽트를 실시하는지,
• 지정된 대기 시간이 경과한다

카운트가 제로에 이르면, 메서드는 값 true로 복귀합니다.

현재의 thread가

• 이 메서드에의 엔트리상에서 설정된 인터럽트 스테이터스를 보관 유지하는지,
• 대기중에인터럽트가 발생했을 경우,

InterruptedException이 Throw 되어 현재의 thread의 인터럽트 스테이터스가 클리어 됩니다.

지정된 대기 시간이 경과하면, 값 false가 리턴됩니다 . 시간이 제로 또는 그것보다 작은 경우, 메서드는 대기하지 않습니다.

파라미터:

timeout - 대기하는 최장 시간

unit - timeout 인수의 시간 단위

반환값:

카운트가 제로에 이르렀을 경우는 true, 카운트가 제로에 이르기 전에 대기 시간이 경과했을 경우는 false

예외:

InterruptedException - 대기중에 현재의 thread로 인터럽트가 발생했을 경우

countDown

public void countDown()

빗장의 카운트를 감산해, 카운트가 제로에 이르면 대기중의 thread를 모두 해방합니다.

현재의 카운트가 제로보다 큰 경우, 값이 줄여집니다. 새로운 카운트가 제로의 경우, 대기중의 모든 thread의 스케줄링이 다시 가능하게 됩니다.

현재의 카운트가 제로의 경우, 아무것도 행해지지 않습니다.

getCount

public long getCount()

현재의 카운트를 리턴합니다.

보통, 이 메서드는 디버그 및 테스트 목적으로 사용합니다.

반환값:

현재의 카운트

toString

public String  toString()

이 빗장 및 그 상태를 식별하는 캐릭터 라인을 리턴합니다. 상태는 괄호로 둘러싸여 캐릭터 라인 「Count =」에 이어 현재의 카운트가 지정됩니다.

오버라이드(override):

클래스 Object 내의 toString

반환값:

이 빗장 및 그 상태를 식별하는 캐릭터 라인