jdk1.5之后,java的concurrent包提供了一些并发工具类,比如CountDownLatch和CyclicBarrier,这里只讲它们的应用场景,暂不作原理剖析。
CountDownLatch:一个线程A等待其它线程都执行完毕后,这个线程A才继续执行。这个线程A也可以是一组线程(使用同一个CountDownLatch来控制即可).
CyclicBarrier:一组线程互相等待,当它们都达到各自await()指定的barrier时,它们再同时继续执行各自下面的代码。
大致实现如下:
CountDownLatch:使用await()让主线程A等待,然后其它线程执行完成时可以使用countDown()使计数减1,最终计数器被清0时,主线程继续执行,计数器是由CountDownLatch初始化时定义的:
final CountDownLatch latch = new CountDownLatch(2);
CyclicBarrier:一组线程使用await()指定barrier,所有线程都到达各自的barrier后,再同时执行各自barrier下面的代码。CyclicBarrier也可以指定当所有线程到达barrier时执行一段代码:
@Override
public void run() {
System.out.println("大家都到了啊!");
}
});```
还有个工具也很实用,Semaphore,可以控制一段代码块同时被访问的线程的个数。通过 acquire() 获取一个许可,如果没有就等待,而 release() 释放一个许可。
public static void main(String[] args) {
int N = 8; //总线程数
Semaphore semaphore = new Semaphore(5); //最多访问线程数5
for(int i=0;i<N;i++)
new Worker(i,semaphore).start();
}
static class Worker extends Thread{
private int num;
private Semaphore semaphore;
public Worker(int num,Semaphore semaphore){
this.num = num;
this.semaphore = semaphore;
}
@Override
public void run() {
try {
semaphore.acquire();
//sleep模拟一个代码块,最多只有5个线程能够执行它,其它线程会被阻塞在上面的acquire()方法,
等待获取许可
Thread.sleep(2000);
semaphore.release();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}`