常用的辅助类

HeJin大约 2 分钟JavaJUC并发编程

CountDownLatch

减法计数器

public class CountDownLatchDemo {
    public static void main(String[] args) throws InterruptedException {
        // 总数是6.必须要执行任务的时候再使用
        CountDownLatch countDownLatch = new CountDownLatch(6);

        for (int i = 0; i < 6; i++) {
            new Thread(() -> {
                // 数量-1
                System.out.println(Thread.currentThread().getName()+" Go out");
                countDownLatch.countDown();
            },String.valueOf(i)).start();
        }

        // 等待计数器归0,然后向下执行
        countDownLatch.await();

        System.out.println("Close door");
    }
}

结果：

1 Go out
4 Go out
3 Go out
2 Go out
0 Go out
5 Go out
Close door

Process finished with exit code 0

原理

// 数量-1
countDownLatch.countDown();
// 等待计数器归0,然后向下执行
countDownLatch.await();

每次有线程调用countDown()方法数量减1,。假设计数器变为0，countDownLatch.await()就会被唤醒，继续执行。

CyclicBarrier

加法计数器

public class CyclicBarrierDemo {
    /**
     * 集齐7颗龙珠召唤神龙
     */
    public static void main(String[] args) {
        // 召唤龙珠的线程
        CyclicBarrier cyclicBarrier = new CyclicBarrier(7, () -> {
            System.out.println("召唤神龙成功");
        });

        for (int i = 1; i <= 7; i++) {
            final int temp = i;
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName() + "收集第-" + temp + "个龙珠");
                try {
                    cyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

结果：

Thread-1收集第2个龙珠
Thread-5收集第6个龙珠
Thread-4收集第5个龙珠
Thread-2收集第3个龙珠
Thread-3收集第4个龙珠
Thread-0收集第1个龙珠
Thread-6收集第7个龙珠
召唤神龙成功

Process finished with exit code 0

Semaphore

信号量

public class SemaphoreDemo {
    public static void main(String[] args) {
        // 默认线程数量：停车位 限流
        Semaphore semaphore = new Semaphore(3);
        for (int i = 1; i <= 6; i++) {
            new Thread(() -> {
                try {
                    // 得到
                    semaphore.acquire();
                    System.out.println(Thread.currentThread().getName()+"抢到车位");
                    TimeUnit.SECONDS.sleep(2);
                    System.out.println(Thread.currentThread().getName()+"离开车位");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    // 释放
                    semaphore.release();
                }
            }, String.valueOf(i)).start();
        }
    }
}

结果：

2抢到车位
3抢到车位
1抢到车位
1离开车位
2离开车位
3离开车位
4抢到车位
6抢到车位
5抢到车位
4离开车位
5离开车位
6离开车位

Process finished with exit code 0

原理

semaphore.acquire();获得。假设已经满了，等待。等待被释放为止。

semaphore.release();释放。会将当前的信号量释放+1，然后唤醒等待的线程。

作用

多个共享资源互斥地使用。
并发限流，控制最大的线程数。

常用的辅助类

# CountDownLatch

# CyclicBarrier

# Semaphore

CountDownLatch

CyclicBarrier

Semaphore