java中常用的并发工具有哪些

这篇文章主要讲解了“java中常用的并发工具有哪些”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“java中常用的并发工具有哪些”吧!

1)闭锁CountDownLatch

功能:让一个主线程等待一组工作线程执行完毕之后,才继续执行主线程,与加入()方法的功能类似。
　　
　　原理:
　　1)CountDownLatch是通过一个计数器来实现的,计数器的初始值为需要等待线程的数量。
　　2)当一个线程完成了自己的任务后,计数器的值就会减1。
　　3)当计数器值为0时,说明所有的线程都执行完了,此时,在闭锁上等待的线程就可以恢复执行任务。
　　
　　注意：
　　1)倒计时()可以在每个线程中调用一次,也可以在一个线程中调用多次。
　　2)计数器必须大于等于0,计数器为0时,调用等待方法时不会阻塞当前线程。

2)屏障(栅栏)CyclicBarrier

功能:让一组线程到达一个屏障时被阻塞,直到最后一个线程到达屏障时,屏障才会开门(旅行),所有被屏障拦截的线程才会继续运行。
　　
　　CyclicBarrier和CountDownLatch的区别:
　　
　　1)CountDownLatch的计数器只能使用一次,而CyclicBarrier的计数器可以使用复位()方法重置。
　　2)到达某个点后,使用CountDownLatch的线程继续运行,使用CyclicBarrier的线程停止运行:
　　使用CountDownLatch的线程运行到某个点之后,调用,倒计时(),方法将计数器的值减1,之后线程继续执行。
　　使用CyclicBarrier 的线程运行到某个点之后,调用,等待(),,,方法使该线程停止运行,直到所有的线程都到达了这个点(调用等待方法),(所有的)线程才可以继续运行。

3)信号量信号量

功能:控制并发的线程数。
　　
　　原理:
　　1)线程通过收购()方法获取许可证。
　　2)线程通过释放()方法归还许可证。
　　
　　说明:使用tryAcquire()方法可以立即得到执行的结果:尝试获取一个许可证,若获取成功,则立即返回真,若获取失败,则立即返回错误的。
　　
　　应用:流量控制,例如数据库连接数的控制等。

4)交换者换热器

功能:两个线程间数据的交换。
　　
　　原理:
　　1)线程一个调用public  V 交换(V  dataA)方法,线程一到达同步点,并且在线程B到达同步点前一直等待。
　　2)线程B调用public  V 交换(V  dataB)方法,线程B到达同步点。
　　3)线程一个与线程B都达到同步点时,线程将自己的数据传递给对方,两个线程完成了数据的交换了。
　　
　　,举例:
　　public  class  ExchangerTest  {
　　public  static  void  main (String [], args), {
　　
　　final  Exchanger< String>, exchanger =, new  Exchanger ();
　　
　　ExecutorService  service =, Executors.newFixedThreadPool (2);
　　
　　service.execute (new  Runnable (), {
　　public  void  run (), {
　　try  {
　　String  originalData =,“dataA";
　　thread . sleep (2000);
　　System.out.println(“线程“,+,Thread.currentThread () . getname(), +,“正在把数据(“时间+大敌;;originalData  +,“]传递出去…“,+,“时间:“,+,System.currentTimeMillis ());
　　String  exchangedData =, exchanger.exchange (originalData);
　　System.out.println(“线程“,+,Thread.currentThread () . getname(), +,“获取到另一线程的数据(“时间+大敌;;exchangedData  +,“]”, +,“时间:“,+,System.currentTimeMillis ());
　　},catch  (Exception  e), {
　　e.printStackTrace ();
　　}
　　}
　　});
　　
　　service.execute (new  Runnable (), {
　　public  void  run (), {
　　try  {
　　String  originalData =,“dataB";
　　thread . sleep (6000);
　　System.out.println(“线程“,+,Thread.currentThread () . getname(), +,“正在把数据(“时间+大敌;;originalData  +,“]传递出去…“,+,“时间:“,+,System.currentTimeMillis ());
　　String  exchangedData =, exchanger.exchange (originalData);
　　System.out.println(“线程“,+,Thread.currentThread () . getname(), +,“获取到另一线程的数据(“时间+大敌;;exchangedData  +,“]”, +,“时间:“,+,System.currentTimeMillis ());
　　},catch  (Exception  e), {
　　e.printStackTrace ();
　　}
　　}
　　});
　　}
　　}
　　
　　结果：
　　线程pool-1-thread-1正在把数据(dataA)传递出去……时间:1506414528645
　　线程pool-1-thread-2正在把数据(dataB)传递出去……时间:1506414532645
　　线程pool-1-thread-2获取到另一线程的数据(dataA)时间:1506414532645
　　线程pool-1-thread-1获取到另一线程的数据(dataB)时间:1506414532645 
java中常用的并发工具有哪些