동시 실행: 스레드 간에 데이터를 교환하는 Exchanger(교환자).

1632 단어 #다선정의 예술
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) {
					e.printStackTrace();
				}
			}
		});
		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) {
					e.printStackTrace();
				}
			}
		});
		threadPool.shutdown();
	}
}

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

좋은 웹페이지 즐겨찾기