import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* @author pengjunzhe
*/
public class ExchangerTest {
private static Exchanger<String> exchanger = new Exchanger<>();
private static ExecutorService threadpool = Executors.newFixedThreadPool(2);
public static void main(String[] args) {
threadpool.execute(() -> {
String A = "银行流水A";
try {
String C = exchanger.exchange(A);
System.out.println("A收到的是:" + C);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
threadpool.execute(() -> {
try {
String B = "银行流水B";
String A= exchanger.exchange("B");
System.out.println("A和B数据是否一致:" + A.equals(B) + ", A录入的是:" + A + ",B录入的是:" + B);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
threadpool.shutdown();
}
}