时间:2021-05-19
java多线程之CyclicBarrier的使用方法
public class CyclicBarrierTest { public static void main(String[] args) { ExecutorService service = Executors.newCachedThreadPool(); final CyclicBarrier cb = new CyclicBarrier(3); for(int i=0;i<3;i++){ Runnable runnable = new Runnable(){ public void run(){ try { Thread.sleep((long)(Math.random()*10000)); System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点1,当前已有" + (cb.getNumberWaiting()+1) + "个已经到达," + (cb.getNumberWaiting()==2?"都到齐了,继续走啊":"正在等候")); cb.await(); Thread.sleep((long)(Math.random()*10000)); System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点2,当前已有" + (cb.getNumberWaiting()+1) + "个已经到达," + (cb.getNumberWaiting()==2?"都到齐了,继续走啊":"正在等候")); cb.await(); Thread.sleep((long)(Math.random()*10000)); System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点3,当前已有" + (cb.getNumberWaiting() + 1) + "个已经到达," + (cb.getNumberWaiting()==2?"都到齐了,继续走啊":"正在等候")); cb.await(); } catch (Exception e) { e.printStackTrace(); } } }; service.execute(runnable); } service.shutdown(); } }运行结果如下:
线程pool-1-thread-3即将到达集合地点1,当前已有1个已经到达,正在等候线程pool-1-thread-1即将到达集合地点1,当前已有2个已经到达,正在等候线程pool-1-thread-2即将到达集合地点1,当前已有3个已经到达,都到齐了,继续走啊线程pool-1-thread-3即将到达集合地点2,当前已有1个已经到达,正在等候线程pool-1-thread-1即将到达集合地点2,当前已有2个已经到达,正在等候线程pool-1-thread-2即将到达集合地点2,当前已有3个已经到达,都到齐了,继续走啊线程pool-1-thread-1即将到达集合地点3,当前已有1个已经到达,正在等候线程pool-1-thread-3即将到达集合地点3,当前已有2个已经到达,正在等候线程pool-1-thread-2即将到达集合地点3,当前已有3个已经到达,都到齐了,继续走啊如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
Java多线程中线程间的通信一、使用while方式来实现线程之间的通信packagecom.ietree.multithread.sync;importjava
CyclicBarrier接着讲多线程下的其他组件,第一个要讲的就是CyclicBarrier。CyclicBarrier从字面理解是指循环屏障,它可以协同多个
IOS多线程编程NSThread的使用方法NSThread是多线程的一种,有两种方法创建子线程(1)优点:NSThread比GCD、NSOperation都轻量
PyQt5简单多线程信号与槽的使用最简单的多线程使用方法是利用QThread函数,展示QThread函数和信号简单结合的方法importsysfromPyQt5
本文实例讲述了Java并发编程之常用的多线程实现方式。分享给大家供大家参考,具体如下:概述常用的多线程实现方式有2种:1. 继承Thread类2. 实现Runn