前言:在你無聊的時候,想想比你優秀還努力的人,也許就不覺的無聊了

今天下午沒事干把買的java并發編程藝術這本書拿出來看了看,看了下也記不住,還是好記性不如爛筆頭,今天講四個并發中可能會用到的工具類,分別是：

CountDownLatch

CyclicBarrier

Semaphore

Exchanger

CountDownLatch

countDownLatch允許一個或多個線程等待其他線程完成操作.比如說有三個線程分別是老二,老大,老爸,這三個線程必須是老二吃好了,老大吃,老大吃完了,老爸吃,在20年錢,農村家里窮,一般有好吃的都是先留個最小的,然后才給其他兄弟姐妹吃,都不吃了,才由我們的父母吃,所以父母都不容易了,為了兒女,雖然是多個線程但是確實線性的,

我同事面試別人就問過好幾次這個問題,在java或者android中常用的有2個方式實現

第一種方式：

使用jdk中Thread自帶的函數join實現,join()用于當前執行線程等待join線程執行結束,其實實現原理是不停檢查join線程是否存活,如果join線程存活則讓當前線程永遠等待,其中,wait(0)表示永遠等待下去,join在jdk中的是實現方式如下：

/**

* Waits for this thread to die.

*

*

An invocation of this method behaves in exactly the same

* way as the invocation

*

*

* {@linkplain #join(long) join}{@code (0)}

*

*

* @throws InterruptedException

* if any thread has interrupted the current thread. The

* interrupted status of the current thread is

* cleared when this exception is thrown.

*/

public final void join() throws InterruptedException {

join(0);

}直到join線程中止后,線程的this.notifyAll()方法會被調用,調用notifyAll()方法是在JVM里實現的,現在把上面的例子用代碼實現下：

package com.thread;

public class RunnableJob {

public static void main(String[] args) throws InterruptedException {

Worker runnableJob = new Worker();

Thread t1 = new Thread(runnableJob, "老二");

Thread t2 = new Thread(runnableJob, "老大");

Thread t3 = new Thread(runnableJob, "老爸");

t1.start();

t1.join();

t2.start();

t2.join();

t3.start();

t3.join();

System.out.println("主線程執行完畢----");

}

}

class Worker implements Runnable{

public void run() {

Thread thread = Thread.currentThread();

try {

Thread.sleep(5000);

System.out.println(thread.getName()+"吃完了");

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}log:

今天寫不完,要下班,明天有時間寫完

總結

以上是生活随笔為你收集整理的java中的并发类_java中并发常用工具类的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。