동시 툴 클래스 (4) 데이터 교환을 위한 두 개의 스레드 Exchanger

소개

Exchanger(교환자)는 스레드 간 협업에 사용되는 도구 클래스입니다.Exchanger는 스레드 간의 데이터 교환에 사용됩니다.그것은 동기점을 제공하는데, 이 동기점 두 라인에서 서로의 데이터를 교환할 수 있다.이 두 라인은 exchange 방법을 통해 데이터를 교환합니다. 만약에 첫 번째 라인이 exchange 방법을 먼저 실행한다면 두 번째 라인도 exchange를 실행하기를 기다릴 것입니다. 두 라인이 모두 동기점에 도달할 때 이 두 라인은 데이터를 교환하여 본 라인이 생산한 데이터를 상대방에게 전달할 수 있습니다.

Exchanger의 응용 장면

Exchanger는 유전 알고리즘에 사용할 수 있다. 유전 알고리즘에서 두 사람을 교배 대상으로 선택해야 한다. 이때 두 사람의 데이터를 교환하고 교차 규칙을 사용하여 2개의 교배 결과를 얻는다.Exchanger는 교정 작업에도 사용할 수 있습니다.예를 들어 우리는 종이로 만든 은류를 인공적인 방식으로 전자은행의 흐름으로 기록해야 한다. 오류를 피하기 위해 AB강으로 두 사람을 기록해야 한다. 엑셀에 기록된 후에 시스템은 이 두 개의 엑셀을 불러오고 이 두 개의 엑셀 데이터를 교정하여 기록의 일치 여부를 확인해야 한다.코드는 다음과 같습니다.

public class ExchangerTest {

	private static final Exchanger exgr = new Exchanger();

	private static ExecutorService threadPool = Executors.newFixedThreadPool(2);

	public static void main(String[] args) {

		threadPool.execute(new Runnable() {
			@Override
			public void run() {
				try {
					String A = " A";// A 
					exgr.exchange(A);
				} catch (InterruptedException e) {
				}
			}
		});

		threadPool.execute(new Runnable() {
			@Override
			public void run() {
				try {
					String B = " B";// B 
					String A = exgr.exchange("B");
					System.out.println("A B ：" + A.equals(B) + ",A ："
							+ A + ",B ：" + B);
				} catch (InterruptedException e) {
				}
			}
		});

		threadPool.shutdown();

	}
}

기타 방법

두 라인에 exchange 방법이 도착하지 않으면 계속 기다립니다. 특수한 상황이 발생할까 봐 계속 기다리지 않으려면 exchange(V x,long timeout,Time Unit unit)를 사용하여 최대 기다림 시간을 설정할 수 있습니다.