并发编程(CountDownLatch使用)
生活随笔
收集整理的這篇文章主要介紹了
并发编程(CountDownLatch使用)
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
一.簡介:
Latch意思是:門閂的意思,形象的來說await就是拴上門閂,等到門閂釋放后當前線程開始工作。
下面是來自簡書上的解釋:
CountDownlatch是一個多功能的同步工具,可以被用于各種目的。一個CountDownLatch通過一個值為1的count被初始化,來作為一個開/關的門或門閂:所有調用了await()的線程都會在門前等待,直到門被一個線程通過調用countDown()打開。一個被初始化為N的CountDownLatch可以被用來“在N個線程都完成了某種操作(或者一些操作已經被完成了N次)之后創建一個線程”。
CountDownLatch一個有用的屬性就是它不需要線程們在繼續執行之前,調用countDown來等待count被減到0。它簡單地阻止了任何調用了await()的線程繼續,直到所有的線程都能夠通過。?
二.實例: 兩個線程各自執行100次,對i加1,等待兩個線程結束輸出i值。 import java.util.concurrent.CountDownLatch;/*** Created by cuijunyong on 2018/2/3.*/ public class Xunhuan {public static int i = 0;private static final CountDownLatch end = new CountDownLatch(2);private static final CountDownLatch start = new CountDownLatch(1);public static void main(String[] args) throws Exception{A a = new A(); // A b = new A();MyThread myThread = new MyThread();Thread b = new Thread(myThread); // Thread[] threads = new Thread[10]; // for(int x = 0; x < threads.length; x++){ // threads[i] = new Thread(myThread); // threads[i].start(); // } a.start();b.start();System.out.println("開始工作了\n");start.countDown();end.await();System.out.println("a:" + a.isAlive());System.out.println("b:" +b.isAlive());System.out.println("i=" + i);}static class MyThread implements Runnable{public void run() { // int i = 0;try {start.await();int j = 0;while (j < 100){j++;i++;System.out.println("B = " + i);}System.out.println("end.count = " + end.getCount());end.countDown();} catch (Exception e) {e.printStackTrace();}}}static class A extends Thread{@Overridepublic void run() { // int i = 0;try {start.await();int j = 0;while (j < 100){j++;i++;System.out.println("A = " + i);}System.out.println("end.count = " + end.getCount());end.countDown();} catch (Exception e) {e.printStackTrace();}}}}結果:前面略略略
A = 190 A = 191 A = 192 A = 193 A = 194 A = 195 B = 171 end.count = 2 B = 196 B = 197 B = 198 B = 199 B = 200 end.count = 1 a:false b:false i=200?
總結
以上是生活随笔為你收集整理的并发编程(CountDownLatch使用)的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Linux查看某个端口是否被占用
- 下一篇: windows 2012 r2 x64