品牌广告公司网站建设,科站网站,网站改版的影响,广州视频制作java除了提供锁之外#xff0c;还提供了一些辅助的同步器。 一、CountDownLatch 作用#xff1a;常常要有一个线程#xff08;master#xff09;做汇总#xff0c;等n个子步骤#xff08;线程slave#xff09;完成后才能继续操作。用join写只能等子线程完成#xff0c;… java除了提供锁之外还提供了一些辅助的同步器。 一、CountDownLatch 作用常常要有一个线程master做汇总等n个子步骤线程slave完成后才能继续操作。用join写只能等子线程完成而且写起来麻烦用wait来写也不是那么容易。 import java.util.concurrent.CountDownLatch;public class TestThread extends Thread{private static final int N5;//指定需要完成的countDown次数private static CountDownLatch countnew CountDownLatch(N);public static void main(String[] args) throws InterruptedException{TestThread ts[]new TestThread[5];for(int i0;iN;i){ts[i] new TestThread(i);ts[i].start();}//等待N次countDowncount.await();int total0;for(int i0;iN;i) totalts[i].getOut();System.out.print(total);}private int in;private int out;public TestThread(int in){this.inin;}public void run(){ try {outin*in;Thread.sleep(1000);//完成子任务汇报count.countDown();} catch (InterruptedException e) {e.printStackTrace();} }public int getOut(){return out;}
} 二、CyclicBarrier 作用最直接的作用是n个线程都完成某步操作后才继续。 CountDownLatch是一个人等N个人就像老师收试卷大家交卷就跑了老师要等齐所有试卷后才能走 CyclicBarrier就是N个人互等就像去春游要等到最后一个人到了大家才能出发。 然而这只是最直接的功能CyclicBarrier完全可以取代CountDownLatch而且功能更灵活可以重置计数。你可以把它看成一个计数器能想到的一些操作 N个一组地处理一件事。 语法参考http://www.cnblogs.com/skywang12345/p/3533995.html 三、Semaphore信号量 作用限制同时访问特定资源的数量比如同时让5个线程同时上传文件。 public class TestThread {public static void main(String[] args) throws InterruptedException{final int THREAD_COUNT 10;for(int i 0 ;i THREAD_COUNT;i){Thread t new Thread(new Task1());t.start();}}}class Task1 implements Runnable{//用信号量设置最多5个线程同时访问资源private static Semaphore s new Semaphore(5);public void run() {try {s.acquire();System.out.println(upload file);Thread.sleep(1000);s.release();} catch (InterruptedException e) {e.printStackTrace();}}
} 四、Exchanger 作用主要用于线程间交换数据转载于:https://www.cnblogs.com/deliver/p/5685195.html
