java.util.concurrent 的工具类使用
2021-01-20 02:14
标签：技术 release runnable lang api thread 计时 ase 更新 一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。 用给定的计数 初始化 demo 一个同步辅助类，它允许一组线程互相等待，直到到达某个公共屏障点 (common barrier point)。在涉及一组固定大小的线程的程序中，这些线程必须不时地互相等待，此时 CyclicBarrier 很有用。因为该 barrier 在释放等待线程后可以重用，所以称它为循环 的 barrier。 CyclicBarrier 支持一个可选的 demo 一个计数信号量。从概念上讲，信号量维护了一个许可集。如有必要，在许可可用前会阻塞每一个 Semaphore 通常用于限制可以访问某些资源（物理或逻辑的）的线程数目。如：四个车位，7个人来抢占。 demo java.util.concurrent 的工具类使用 标签：技术 release runnable lang api thread 计时 ase 更新 原文地址：https://www.cnblogs.com/fengyangcai/p/12903171.html类 CountDownLatch 倒计时锁
CountDownLatch。由于调用了 countDown() 方法，所以在当前计数到达零之前，await 方法会一直受阻塞。之后，会释放所有等待的线程，await 的所有后续调用都将立即返回。这种现象只出现一次——计数无法被重置。如果需要重置计数，请考虑使用 CyclicBarrier。
public static void main(String[] args) throws InterruptedException {
CountDownLatch countDownLatch = new CountDownLatch(8);
for (int i = 0; i ) {
new Thread(() -> {
System.out.println(Thread.currentThread().getName()+"\t下班");
countDownLatch.countDown();
}, String.valueOf(i)).start();
}
countDownLatch.await();
//在没有使用countDownLatch之前可能这行代码就先执行了
System.out.println(Thread.currentThread().getName()+"\t保安关门");
}
类 CyclicBarrier （循环栅栏）
Runnable 命令，在一组线程中的最后一个线程到达之后（但在释放所有线程之前），该命令只在每个屏障点运行一次。若在继续所有参与线程之前更新共享状态，此屏障操作 很有用。public class CyclicBarrierDemo {
public static void main(String[] args) {
// public CyclicBarrier(int parties, Runnable barrierAction)
CyclicBarrier cyclicBarrier =new CyclicBarrier(7, ()-> {System.out.println("召唤神龙");} );
for (int i = 0; i ) {
final int tempInt=i;
new Thread(() -> {
System.out.println(Thread.currentThread().getName()+"\t收集到了第："+tempInt+"--龙珠");
try {
cyclicBarrier.await();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (BrokenBarrierException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}, String.valueOf(i)).start();
}
}
}
类 Semaphore 信号标（灯）
acquire()，然后再获取该许可。每个 release() 添加一个许可，从而可能释放一个正在阻塞的获取者。但是，不使用实际的许可对象，Semaphore 只对可用许可的号码进行计数，并采取相应的行动。public class SemaphoreDemo {
public static void main(String[] args) {
//从此信号量获取一个许可，在提供一个许可前一直将线程阻塞，否则线程被中断。
//如果Semaphore(1)相当与synchronized
Semaphore semaphore = new Semaphore(4);// 模拟资源类，有4个空车位
for (int i = 0; i ) {
new Thread(() -> {
try {
semaphore.acquire();
System.out.println(Thread.currentThread().getName() + "\t抢到了车位");
// 暂停一下线程
try {
TimeUnit.SECONDS.sleep(3);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
//释放一个许可，将其返回给信号量。
semaphore.release();
}
}, String.valueOf(i)).start();
}
}
}
文章标题：java.util.concurrent 的工具类使用
文章链接：http://soscw.com/index.php/essay/44334.html