java并发工具类（CountDownLatch+Semaphore+Exchanger）
需积分: 0 200 浏览量
2023-06-20
14:22:02
上传
评论
收藏 39KB DOCX 举报
java 并发工具类
1. 倒计时器 CountDownLatch
在多线程协作完成业务功能时，有时候需要等待其他多个线程完成任务之后，主
线程才能继续往下执行业务功能，在这种的业务场景下，通常可以使用 Thread
类的 join 方法，让主线程等待被 join 的线程执行完之后，主线程才能继续往下
执行。当然，使用线程间消息通信机制也可以完成。其实，java 并发工具类中
为我们提供了类似“倒计时”这样的工具类，可以十分方便的完成所说的这种业务
场景。
为了能够理解 CountDownLatch，举一个很通俗的例子，运动员进行跑步比赛时，
假设有 6 个运动员参与比赛，裁判员在终点会为这 6 个运动员分别计时，可以
想象没当一个运动员到达终点的时候，对于裁判员来说就少了一个计时任务。直
到所有运动员都到达终点了，裁判员的任务也才完成。这 6 个运动员可以类比
成 6 个线程，当线程调用 CountDownLatch.countDown 方法时就会对计数器的
值减一，直到计数器的值为 0 的时候，裁判员（调用 await 方法的线程）才能
继续往下执行。
下面来看些 CountDownLatch 的一些重要方法。
先从 CountDownLatch 的构造方法看起：
java
复制代码
public CountDownLatch(int count)
构造方法会传入一个整型数 N，之后调用 CountDownLatch 的 countDown 方法
会对 N 减一，知道 N 减到 0 的时候，当前调用 await 方法的线程继续执行。
CountDownLatch 的方法不是很多，将它们一个个列举出来：
1. await() throws InterruptedException：调用该方法的线程等到构造方法传入的 N 减
到 0 的时候，才能继续往下执行；
2. await(long timeout, TimeUnit unit)：与上面的 await 方法功能一致，只不过这里有了
时间限制，调用该方法的线程等到指定的 timeout 时间后，不管 N 是否减至为 0，
都会继续往下执行；
3. countDown()：使 CountDownLatch 初始值 N 减 1；
4. long getCount()：获取当前 CountDownLatch 维护的值；
下面用一个具体的例子来说明 CountDownLatch 的具体用法:
剩余12页未读，继续阅读
资源评论
