辅助同步器
java除了提供鎖之外,還提供了一些輔助的同步器。
一、CountDownLatch
作用:常常要有一個線程(master)做匯總,等n個子步驟(線程slave)完成后才能繼續操作。用join寫只能等子線程完成,而且寫起來麻煩;用wait來寫也不是那么容易。
import java.util.concurrent.CountDownLatch;public class TestThread extends Thread{private static final int N=5;//指定需要完成的countDown次數private static CountDownLatch count=new CountDownLatch(N);public static void main(String[] args) throws InterruptedException{TestThread ts[]=new TestThread[5];for(int i=0;i<N;i++){ts[i]= new TestThread(i);ts[i].start();}//等待N次countDown count.await();int total=0;for(int i=0;i<N;i++) total+=ts[i].getOut();System.out.print(total);}private int in;private int out;public TestThread(int in){this.in=in;}public void run(){ try {out=in*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
總結
- 上一篇: android stub,Android
- 下一篇: 区块链java开源框架_github上的