在多線程開發中，常常遇到希望一組線程完成之后在執行之后的操作，java提供了一個多線程同步輔助類，可以完成此類需求：
類中常見的方法：
其中構造方法：
CountDownLatch(int count) 參數count是計數器，一般用要執行線程的數量來賦值。
long getCount()：獲得當前計數器的值。
void countDown()：當計數器的值大于零時，調用方法，計數器的數值減少1，當計數器等數零時，釋放所有的線程。
void await()：調所該方法阻塞當前主線程，直到計數器減少為零。
代碼例子：
線程類：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
import java.util.concurrent.CountDownLatch;public class TestThread extends Thread{CountDownLatch cd;String threadName;public TestThread(CountDownLatch cd,String threadName){ this.cd=cd; this.threadName=threadName;}@Overridepublic void run() { System.out.println(threadName+" start working..."); dowork(); System.out.println(threadName+" end working and exit..."); cd.countDown();//告訴同步類完成一個線程操作完成}private void dowork(){ try { Thread.sleep(2000); System.out.println(threadName+" is working..."); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); }}} |
測試類：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
import java.util.concurrent.CountDownLatch;public class TsetCountDownLatch { public static void main(String[] args) { try { CountDownLatch cd = new CountDownLatch(3);// 表示一共有三個線程 TestThread thread1 = new TestThread(cd, "thread1"); TestThread thread2 = new TestThread(cd, "thread2"); TestThread thread3 = new TestThread(cd, "thread3"); thread1.start(); thread2.start(); thread3.start(); cd.await();//等待所有線程完成 System.out.println("All Thread finishd"); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } }} |
輸出結果：
|
1
2
3
4
5
6
7
8
9
10
|
thread1 start working...thread2 start working...thread3 start working...thread2 is working...thread2 end working and exit...thread1 is working...thread3 is working...thread3 end working and exit...thread1 end working and exit...All Thread finishd |
以上就是本文的全部內容，希望本文的內容對大家的學習或者工作能帶來一定的幫助，同時也希望多多支持服務器之家!
原文鏈接：http://www.cnblogs.com/ITer-jack/p/6791803.html
