并发工具之 Semaphore 与 Exchanger

System.out.println(Thread.currentThread().getName() + " 填写完表格，归还了笔！！！！！！");

} catch (InterruptedException e) {

e.printStackTrace();

}

});

}

service.shutdown();

}

}

输出结果

pool-1-thread-2 同学准备获取笔......

pool-1-thread-4 同学准备获取笔......

pool-1-thread-5 同学准备获取笔......

pool-1-thread-3 同学准备获取笔......

pool-1-thread-3 同学获取到笔

pool-1-thread-1 同学准备获取笔......

pool-1-thread-3 填写表格 ing.....

pool-1-thread-9 同学准备获取笔......

pool-1-thread-8 同学准备获取笔......

pool-1-thread-5 同学获取到笔

pool-1-thread-5 填写表格 ing.....

pool-1-thread-4 同学获取到笔

pool-1-thread-4 填写表格 ing.....

pool-1-thread-6 同学准备获取笔......

pool-1-thread-2 同学获取到笔

pool-1-thread-2 填写表格 ing.....

pool-1-thread-10 同学准备获取笔......

pool-1-thread-7 同学准备获取笔......

pool-1-thread-1 同学获取到笔

pool-1-thread-1 填写表格 ing.....

pool-1-thread-4 填写完表格，归还了笔！！！！！！

pool-1-thread-10 同学获取到笔

pool-1-thread-10 填写表格 ing.....

pool-1-thread-7 同学获取到笔

pool-1-thread-7 填写表格 ing.....

pool-1-thread-6 同学获取到笔

pool-1-thread-6 填写表格 ing.....

pool-1-thread-9 同学获取到笔

pool-1-thread-9 填写表格 ing.....

pool-1-thread-5 填写完表格，归还了笔！！！！！！

pool-1-thread-8 同学获取到笔

pool-1-thread-3 填写完表格，归还了笔！！！！！！

pool-1-thread-1 填写完表格，归还了笔！！！！！！

pool-1-thread-2 填写完表格，归还了笔！！！！！！

pool-1-thread-8 填写表格 ing.....

pool-1-thread-7 填写完表格，归还了笔！！！！！！

pool-1-thread-6 填写完表格，归还了笔！！！！！！

pool-1-thread-10 填写完表格，归还了笔！！！！！！

p 《一线大厂 Java 面试题解析+后端开发学习笔记+最新架构讲解视频+实战项目源码讲义》开源 ool-1-thread-8 填写完表格，归还了笔！！！！！！

pool-1-thread-9 填写完表格，归还了笔！！！！！！

根据输出结果进行分析，Semaphore 允许的最大许可数为 5，也就是允许的最大并发执行的线程个数为 5，可以看出，前 5 个线程（前 5 个学生）先获取到笔，然后填写表格，而 6-10 这 5 个线程，由于获取不到许可，只能阻塞等待。当线程pool-1-thread-4释放了许可之后，pool-1-thread-10就可以获取到许可，继续往下执行。对其他线程的执行过程，也是同样的道理。从这个例子就可以看出，Semaphore 用来做特殊资源的并发访问控制是相当合适的，如果有业务场景需要进行流量控制，可以优先考虑 Semaphore。

[](()线程间交换数据的工具 Exchanger

Exchanger 是一个用于线程间协作的工具类，用于两个线程间交换数据。它提供了一个交换的同步点，在这个同步点两个线程能够交换数据。交换数据是通过 exchange 方法来实现的，如果一个线程先执行 exchange 方法，那么它会同步等待另一个线程也执行 exchange 方法，这个时候两个线程就都达到了同步点，两个线程就可以交换数据。

Exchanger 除了一个无参的构造方法外，主要方法也很简单：

//当一个线程执行该方法的时候，会等待另一个线程也执行该方法，因此两个线程就都达到了同步点

//将数据交换给另一个线程，同时返回获取的数据

V exchange(V x) throws InterruptedException

//同上一个方法功能基本一样，只不过这个方法同步等待的时候，增加了超时时间

V exchange(V x, long timeout, TimeUnit unit)

throws InterruptedException, TimeoutException

一个例子

Exchanger 理解起来很容易，这里用一个简单的例子来看下它的具体使用。我们来模拟这样一个情景，在青春洋溢的中学时代，下课期间，男生经常会给走廊里为自己喜欢的女孩子送情书，相信大家都做过这样的事情吧。男孩会先到女孩教室门口，然后等女孩出来，教室那里就是一个同步点，然后彼此交换信物，也就是彼此交换了数据。现在，就来模拟这个情景。

public class ExchangerDemo {

private stat Java 开源项目【ali1024.coding.net/public/P7/Java/git】 ic Exchanger<String> exchanger = new Exchanger();

public static void main(String[] args) {

//代表男生和女生

ExecutorService service = Executors.newFixedThreadPool(2);

service.execute(() -> {

try {

//男生对女生说的话

String girl = exchanger.exchange("我其实暗恋你很久了......");

System.out.println("女孩儿说：" + girl);

} catch (InterruptedException e) {

e.printStackTrace();

}

});

总结

这个月马上就又要过去了，还在找工作的小伙伴要做好准备了，小编整理了大厂 java 程序员面试涉及到的绝大部分面试题及答案，希望能帮助到大家