java.util.concurrent
클래스 CyclicBarrier

java.lang.Object 
  java.util.concurrent.CyclicBarrier

public class CyclicBarrier
extends Object 

thread 세트의 각각이 공통의 바리어 포인트에 이를 때까지 대기하는 것을 가능하게 하는 동기화 지원 기능. CyclicBarrier는 서로 대기하는 것이 때때로 필요하게 되는 고정 사이즈의 thread 파티가 관계된 프로그램으로 유용합니다. 바리어는 대기중의 thread가 해방된 후에 재이용할 수 있기 때문에 「순환식」이라고 불립니다.

CyclicBarrier 는 옵션 Runnable 커멘드를 지원 합니다. 이것은 마지막 thread가 도착한 후에 어느 thread도 해방되기 전에 바리어 포인트 마다 1회 실행됩니다. 이 「바리어 액션」은 파티중 한쪽이 처리를 속행하기 전에 공유 상태를 갱신하는데 도움이 됩니다.

사용례: 차에 병렬 분해 설계에서의 바리어의 사용예를 나타냅니다.

 class Solver {
   final int N;
   final float[][] data;
   final CyclicBarrier barrier;
   
   class Worker implements Runnable {
     int myRow;
     Worker(int row) { myRow = row; }
     public void run() {
       while (! done()) {
         processRow(myRow);

         try {
           barrier.await(); 
         } catch (InterruptedException ex) { 
           return; 
         } catch (BrokenBarrierException ex) { 
           return; 
         }
       }
     }
   }

   public Solver(float[][] matrix) {
     data = matrix;
     N = matrix.length;
     barrier = new CyclicBarrier(N, 
                                 new Runnable() {
                                   public void run() { 
                                     mergeRows(...); 
                                   }
                                 });
     for (int i = 0; i < N; ++i) 
       new Thread(new Worker(i)). start();

     waitUntilDone();
   }
 }
 

여기서, 각 워크스 레드는 행렬의 행을 처리해, 모든 행이 처리될 때까지 바리어로 대기합니다. 모든 행이 처리되면, 지정된 Runnable 바리어 액션이 실행되어, 행을 머지 합니다. 솔루션이 검출된 것을 마쟈가 판별하면, done()가 true를 돌려주고, 각 워카가 종료합니다.

바리어 액션이 실행시에 중단된 파티에 존하고 있지 않는 경우, 그 액션이 해방되면, 파티내의 몇개의 thread가 그것을 실행할 수 있습니다. 이것을 용이하게 하기 위한, await() 각 호출은 바리어의 위치에서 그 thread의 도착 인덱스를 리턴합니다. 그 후, 바리어 액션을 실행하는 thread를 선택할 수 있습니다. 다음에 예를 나타냅니다.

  if (barrier.await() == 0) {
     // log the completion of this iteration
   }

CyclicBarrier는 실패한 동기화의 시도에 대해서 파스트페일로 전인가 무인가의 절단 모델을 사용합니다. 끼어들어, 실패, 또는 타임 아웃을 위해서 thread가 바리어 포인트를 미성숙로의해 두면, 전의 await() 로부터 재개되어 있지 않은 thread를 포함한, 다른 모든 thread에서도 BrokenBarrierException (이것들에서도 거의 동시에 인터럽트가 발생하는 경우는 InterruptedException)를 개입시켜 이상한 상태가 계속됩니다.

도입된 버전 :

1.5

관련 항목:

CountDownLatch

생성자 개요

CyclicBarrier (int parties)
지정된 수의 파티 (thread)가 대기 상태에 있는 경우에 여행 하는 새로운 CyclicBarrier를 작성합니다.

CyclicBarrier (int parties, Runnable barrierAction)
지정된 수의 파티 (thread)가 대기 상태에 있는 경우에 여행 하는 새로운 CyclicBarrier를 작성합니다.

메서드 개요

int	await () 모든파티가 이 바리어로 await를 호출할 때까지 대기합니다.
int	await (long timeout, TimeUnit unit) 모든파티가 이 바리어로 await를 호출할 때까지 대기합니다.
int	getNumberWaiting () 바리어로 대기하고 있는 파티의 수를 리턴합니다.
int	getParties () 이 바리어의 여행에 필요한 파티의 수를 리턴합니다.
boolean	isBroken () 이 바리어가 고장 상태에 있을지 어떨지를 문의합니다.
void	reset () 바리어를 초기 상태에 리셋 합니다.

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

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

생성자 상세

CyclicBarrier

public CyclicBarrier(int parties,
                     Runnable  barrierAction)

지정된 수의 파티 (thread)가 대기 상태에 있는 경우에 여행 하는 새로운 CyclicBarrier를 작성합니다. 바리어의 트립시에는 지정된 바리어 액션이, 바리어에 들어간 마지막 thread에 의해 실행됩니다.

파라미터:

parties - 바리어가 여행 하기 전에 await()를 호출할 필요가 있는 thread의 수

barrierAction - 바리어의 트립시에 실행하는 커멘드. 액션이 존재하지 않는 경우는 null

예외:

IllegalArgumentException - parties가 1 미만의 경우

CyclicBarrier

public CyclicBarrier(int parties)

지정된 수의 파티 (thread)가 대기 상태에 있는 경우에 여행 하는 새로운 CyclicBarrier를 작성합니다. 각 바리어에 대한 정의 끝난 액션은 실행되지 않습니다.

파라미터:

parties - 바리어가 여행 하기 전에 await()를 호출할 필요가 있는 thread의 수

예외:

IllegalArgumentException - parties가 1 미만의 경우

메서드의 상세

getParties

public int getParties()

이 바리어의 여행에 필요한 파티의 수를 리턴합니다.

반환값:

이 바리어의 여행에 필요한 파티의 수

await

public int await()
          throws InterruptedException,

                 BrokenBarrierException 

모든파티가 이 바리어로 await를 호출할 때까지 대기합니다.

현재의 thread가 마지막에 도착하는 thread가 아닌 경우, thread의 스케줄링에 대해서는 무효로 여겨져 다음중 한쪽이 발생할 때까지 대기합니다.

• 마지막 thread가 도착한다
• 다른 thread가 현재의 thread에인터럽트를 실시한다
• 다른 thread가 대기중의 다른 thread의 1개에 인터럽트를 실시한다
• 바리어의 대기중에 다른 thread가 타임 아웃 한다
• 다른 thread가 이 바리어에 대해서 reset()를 호출한다

현재의 thread로

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

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

몇개의 thread가 대기중에 바리어로 reset() 가 실행되는지, await 호출시 또는 몇개의 thread가 대기중에 바리어가파괴되었을 경우, BrokenBarrierException을 발생시킵니다.

대기중에 몇개의 thread로인터럽트가 발생했을 경우, 대기중의 다른 thread가 모두 BrokenBarrierException를 Throw 해, 바리어가 고장 상태에 놓여집니다.

현재의 thread가 도착하는 마지막 thread이며, 생성자내에서 null이 아닌 바리어 액션이 지정되는 경우, 현재의 thread는 액션을 실행하고 나서, 다른 thread의 속행을 허용합니다. 바리어 액션중에 예외가 발생하면, 현재의 thread내에서 그 예외가 송신되어 바리어가 고장 상태에 놓여집니다.

반환값:

현재의 thread의 도착 인덱스. 인덱스 getParties() - 1 은 최초로 도착하는 thread를, 제로는 마지막에 도착하는 thread를 나타낸다

예외:

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

BrokenBarrierException - 현재의 thread의 대기중에 다른 thread로 인터럽트가 발생한, 바리어가 리셋 된, await 호출시에 바리어가 파괴된, 또는 예외를 위해서 바리어 액션 (존재하는 경우)이 실패했을 경우

await

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

                 BrokenBarrierException,

                 TimeoutException 

모든파티가 이 바리어로 await를 호출할 때까지 대기합니다.

현재의 thread가 마지막에 도착하는 thread가 아닌 경우, thread의 스케줄링에 대해서는 무효로 여겨져 아래의 어떤 것인가가 발생할 때까지 대기합니다.

• 마지막 thread가 도착한다
• 지정된 타임 아웃 시간이 경과한다
• 다른 thread가 현재의 thread에인터럽트를 실시한다
• 다른 thread가 대기중의 다른 thread의 1개에 인터럽트를 실시한다
• 바리어의 대기중에 다른 thread가 타임 아웃 한다
• 다른 thread가 이 바리어에 대해서 reset()를 호출한다

현재의 thread로

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

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

지정된 대기 시간이 경과하면, TimeoutException을 발생시킵니다. 시간이 제로 또는 그것보다 작은 경우, 메서드는 대기하지 않습니다.

몇개의 thread가 대기중에 바리어로 reset() 가 실행되는지, await 호출시 또는 몇개의 thread가 대기중에 바리어가파괴되었을 경우, BrokenBarrierException을 발생시킵니다.

대기중에 몇개의 thread로인터럽트가 발생했을 경우, 대기중의 다른 thread가 모두 BrokenBarrierException를 Throw 해, 바리어가 고장 상태에 놓여집니다.

현재의 thread가 도착하는 마지막 thread이며, 생성자내에서 null이 아닌 바리어 액션이 지정되는 경우, 현재의 thread는 액션을 실행하고 나서, 다른 thread의 속행을 허용합니다. 바리어 액션중에 예외가 발생하면, 현재의 thread내에서 그 예외가 송신되어 바리어가 고장 상태에 놓여집니다.

파라미터:

timeout - 바리어를 대기하는 시간

unit - timeout 파라미터의 시간 단위

반환값:

현재의 thread의 도착 인덱스. 인덱스 getParties() - 1 은 최초로 도착하는 thread를, 제로는 마지막에 도착하는 thread를 나타낸다

예외:

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

TimeoutException - 지정된 타임 아웃 시간이 경과했을 경우

BrokenBarrierException - 현재의 thread의 대기중에 다른 thread로 인터럽트가 발생한, 바리어가 리셋 된, await 호출시에 바리어가 파괴된, 또는 예외를 위해서 바리어 액션 (존재하는 경우)이 실패했을 경우

isBroken

public boolean isBroken()

이 바리어가 고장 상태에 있을지 어떨지를 문의합니다.

반환값:

구축 또는 마지막 리셋 이후, 끼어들어 또는 타임 아웃을 위해서 1개 이상의 파티가 이 바리어로부터 파괴되었는지, 예외를 위해서 바리어 액션이 실패했을 경우는 true, 그렇지 않은 경우는 false

reset

public void reset()

바리어를 초기 상태에 리셋 합니다. 몇개의 파티가 바리어로 대기중의 경우는 BrokenBarrierException를 Throw의해 복귀합니다. 다른 이유로써 절단이 발생한 뒤에 리셋 하는 경우는 실행이 복잡하게 되는 경우가 있습니다. 즉, 다른 어떠한 방법으로 thread를 재동기 해, 리셋를 실행하는 thread를 선택할 필요가 있습니다. 이러한 상황에서는 이후에 사용하기 위해서 바리어를 새로운 작성하는 (분)편이 바람직한 경우가 있습니다.

getNumberWaiting

public int getNumberWaiting()

바리어로 대기하고 있는 파티의 수를 리턴합니다. 이 메서드는 주로 디버그 및 선언으로 도움이 됩니다.

반환값:

await() 내에서 현재 블록 되고 있는 파티의 수