java 线程篇 之CyclicBarrier、CountDownLatch、Semaphore

java 提供了很多控制线程到达某一状态导致之前阻塞线程运行的函数，这些在控制任务执行提供了很大的便利，比如在zookper 使用Semaphore实现分布式锁

1、CountDownLatch

countDownLatch 提供 await()，CountDownLatch()来控制，前面我很多例子，使用这个来模拟多线程运行的，所以这里不过多介绍

2、CyclicBarrier

CyclicBarrier 和 CountDownLatch差不多，都市提供一个计数器屏障，当所有线程都到达屏障时，一起执行

public class CyCliBarrierTest implements Runnable{ private static final CyclicBarrier barrier = new CyclicBarrier(10, new Runnable() { @Override public void run() { System.out.println("所有线程到达barrier数量执行..."); } });

1private  CyclicBarrier barrier1;
2public CyCliBarrierTest(CyclicBarrier barrier1) {
3    this.barrier1 = barrier1;
4}
5
6public static void main(String\[\] args) {
7    for(int i = 0; i< 10; i++){
8       new Thread(new CyCliBarrierTest(barrier)).start();
9    }
10}
11
12
13@Override
14public void run() {
15    try {
16        System.out.println(Thread.currentThread().getName()+"wait...");
17        barrier.await();
18    } catch (InterruptedException e) {
19        e.printStackTrace();
20    } catch (BrokenBarrierException e) {
21        e.printStackTrace();
22    }
23    System.out.println(Thread.currentThread().getName()+"start...");
24}

}

3、Semaphore

Semaphore 是一个信号类，当线程运行通过时，执行任务

public class SemaphoreTest { private static final int Max = 2; private static final Semaphore phore = new Semaphore(Max); private static final ExecutorService executor = Executors.newFixedThreadPool(5);

1public static void main(String\[\] args) {
2
3    for(int i=0;i<5;i++){
4        Thread thread = new Thread(new Runnable() {
5            @Override
6            public void run() {
7                try {
8                    phore.acquire(); //最大运行两个任务获取信号
9                    System.out.println("执行任务...");
10                    Thread.sleep(2000);
11                    phore.release();
12                } catch (InterruptedException e) {
13                    e.printStackTrace();
14                }
15            }
16        });
17        executor.submit(thread);
18    }

        executor.shutdown(); }

}

Semaphore  提供了一个tryAcquire()来运行获取到信号的运行，没有获取到执行下面逻辑，有点类似tryLock(),

我们对山面改造下

for(int i=0;i<5;i++){ Thread thread = new Thread(new Runnable() { @Override public void run() { try { if(phore.tryAcquire()){ System.out.println("执行任务..."); Thread.sleep(2000); phore.release(); }else{ System.out.println("没有获取到执行权限..."); } } catch (InterruptedException e) { e.printStackTrace(); } } }); executor.submit(thread); } executor.shutdown();

结果

执行任务...
执行任务...
没有获取到执行权限...
没有获取到执行权限...
没有获取到执行权限...