Exchanger--线程执行过程中交换数据

import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * @author sulishi
 * @version 1.0
 * @date 2021/1/31
 */
public class ExchangerTest {
    private static final Exchanger<String> exgr = new Exchanger<String>();
    private static ExecutorService threadPool = Executors.newFixedThreadPool(2);

    public static void main(String[] args) {
        threadPool.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    // 线程A执行结果
                    String threadResultOfA = "111";
                    exgr.exchange(threadResultOfA);
                }
                catch (InterruptedException e) {
                }
            }
        });
        threadPool.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    // 线程B执行结果
                    String threadResultOfB = "222";
                    String a = exgr.exchange(threadResultOfB);
                    System.out.println("数据是否一致：" + a.equals(threadResultOfB));
                }
                catch (InterruptedException e) {
                }
            }
        });
        threadPool.shutdown();
    }
}

结果： 数据不一致

如果两个线程有一个没有执行exchange()方法，则会一直等待，如果担心有特殊情况发生，避免一直等待，可以使用exchange（V x，longtimeout，TimeUnit unit）设置最大等待时长。