java.util.concurrent
클래스 Exchanger<V>

java.lang.Object 
  java.util.concurrent.Exchanger<V>

형태 파라미터:

V - 교환 가능한 객체의 형태

public class Exchanger<V>
extends Object 

2개의 thread가 객체를 교환 가능한 동기 포인트. 각 thread는 엔트리상의 객체를 exchange 메서드에 제공해, 다른 thread의 제공하는 객체를 대신에 받습니다.

사용예: 이하에 Exchanger를 사용해 thread간에 버퍼를 교환하는 클래스의 주요 부분을 나타냅니다. 버퍼를 채우는 thread가 필요에 따라서 새로운 비어있는 버퍼를 취득해, 버퍼를 비우는 thread에 채워진 버퍼를 건네줍니다.

class FillAndEmpty {
Exchanger<DataBuffer> exchanger = new Exchanger();
DataBuffer initialEmptyBuffer = ... a made-up type
DataBuffer initialFullBuffer = ...

class FillingLoop implements Runnable {
public void run() {
DataBuffer currentBuffer = initialEmptyBuffer;
try {
while (currentBuffer ! = null) {
addToBuffer(currentBuffer);
if (currentBuffer.full())
currentBuffer = exchanger.exchange(currentBuffer);
}
} catch (InterruptedException ex) { ... handle ... }
}
}

class EmptyingLoop implements Runnable {
public void run() {
DataBuffer currentBuffer = initialFullBuffer;
try {
while (currentBuffer ! = null) {
takeFromBuffer(currentBuffer);
if (currentBuffer.empty())
currentBuffer = exchanger.exchange(currentBuffer);
}
} catch (InterruptedException ex) { ... handle ...}
}
}

void start() {
new Thread(new FillingLoop()). start();
new Thread(new EmptyingLoop()). start();
}
}

도입된 버전 :

1.5

생성자 개요

Exchanger ()
새로운 Exchanger를 작성합니다.

메서드 개요

V	exchange (V x) 인터럽트가 발생하지 않는 한, 다른 thread가 이 교환 포인트에 도달할 때까지 대기해, 지정된 객체를 그 thread에 전송 해, 대신에 객체를 받습니다.
V	exchange (V x, long timeout, TimeUnit unit) 인터럽트가 발생하는지, 지정된 대기 시간이 경과하지 않는 한, 다른 thread가 이 교환 포인트에 도달할 때까지 대기해, 지정된 객체를 그 thread에 전송 해, 대신에 객체를 받습니다.

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

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

생성자 상세

Exchanger

public Exchanger()

새로운 Exchanger를 작성합니다.

메서드의 상세

exchange

public V  exchange(V  x)
           throws InterruptedException 

인터럽트가 발생하지 않는 한, 다른 thread가 이 교환 포인트에 도달할 때까지 대기해, 지정된 객체를 그 thread에 전송 해, 대신에 객체를 받습니다.

다른 thread가 이미 교환 포인트로 대기하고 있는 경우, 재개해 thread의 스케줄링을 실행해, 현재의 thread가 건네주는 객체를 받습니다. 현재의 thread는 즉시 복귀해, 다른 thread로부터 교환용으로 건네받는 객체를 받습니다.

교환 포인트로 대기중의 다른 thread가 존재하지 않는 경우, 현재의 thread는 thread 스케줄링에 대해 무효로 여겨져 다음의 2개 중 한쪽이 발생할 때까지 대기합니다.

• 다른 thread가 교환에 들어간다
• 다른 thread가 현재의 thread에인터럽트를 실시한다

현재의 thread가

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

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

파라미터:

x - 교환하는 객체

반환값:

다른 thread에 의해 제공되는 객체

예외:

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

exchange

public V  exchange(V  x,
                  long timeout,
                  TimeUnit  unit)
           throws InterruptedException,

                  TimeoutException 

인터럽트가 발생하는지, 지정된 대기 시간이 경과하지 않는 한, 다른 thread가 이 교환 포인트에 도달할 때까지 대기해, 지정된 객체를 그 thread에 전송 해, 대신에 객체를 받습니다.

다른 thread가 이미 교환 포인트로 대기하고 있는 경우, 재개해 thread의 스케줄링을 실행해, 현재의 thread가 건네주는 객체를 받습니다. 현재의 thread는 즉시 복귀해, 다른 thread로부터 교환용으로 건네받는 객체를 받습니다.

교환 포인트로 대기중의 다른 thread가 존재하지 않는 경우, 현재의 thread는 thread 스케줄링에 대해 무효로 여겨져 다음의 3 개중 한쪽이 발생할 때까지 대기합니다.

• 다른 thread가 교환에 들어간다
• 다른 thread가 현재의 thread에인터럽트를 실시한다
• 지정된 대기 시간이 경과한다

현재의 thread가

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

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

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

파라미터:

x - 교환하는 객체

timeout - 대기하는 최장 시간

unit - timeout 인수의 시간 단위

반환값:

다른 thread에 의해 제공되는 객체

예외:

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

TimeoutException - 별의 thread가 교환에 들어가기 전에 지정된 대기 시간이 경과했을 경우