import java.util.concurrent.Exchanger;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import org.junit.Test;

public class JavaExchanger {

private Exchanger<String> exchanger = new Exchanger<>();

private ExecutorService service = Executors.newFixedThreadPool(2);

@Test

public void test() {

service.execute(new Runnable() {

@Override

public void run() {

try {

String A = "银行流水A";

exchanger.exchange(A);

} catch (Exception e) {

// TODO: handle exception

}

}

});

service.execute(new Runnable() {

@Override

public void run() {

try {

String B = "银行流水B";

String A = exchanger.exchange(B);

System.out.println("A和B数据是否一致： " + A.equals(B) + ", A录入的是： " + A + ", B录入的是： " + B);

} catch (Exception e) {

// TODO: handle exception

}

}

});

service.shutdown();

}

}