Java騷操作之CountDownLatch代碼詳解
更新時間：2021年02月19日 10:45:39 作者：Java Pro
這篇文章主要介紹了Java騷操作之CountDownLatch代碼詳解,本文通過實例圖文相結合給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
簡述
用來干嘛的？當你在方法中調(diào)用了多個線程，對數(shù)據(jù)庫進行了一些不為人知的操作后，還有一個操作需要留到前者都執(zhí)行完的重頭戲，就需要用到 CountDownLatch 了
實踐代碼
package com.github.gleans;
import java.util.concurrent.CountDownLatch;
public class TestCountDownLatch {
public static void main(String[] args) throws InterruptedException {
CountDownLatch latch = new CountDownLatch(3);
new KeyPass(1000L, "thin jack", latch).start();
new KeyPass(2000L, "noral jack", latch).start();
new KeyPass(3000L, "fat jack", latch).start();
latch.await();
System.out.println("此處對數(shù)據(jù)庫進行最后的插入操作~");
}
static class KeyPass extends Thread {
private long times;
private CountDownLatch countDownLatch;
public KeyPass(long times, String name, CountDownLatch countDownLatch) {
super(name);
this.times = times;
this.countDownLatch = countDownLatch;
}
@Override
public void run() {
try {
System.out.println("操作人：" + Thread.currentThread().getName()
+ "對數(shù)據(jù)庫進行插入，持續(xù)時間：" + this.times / 1000 + "秒");
Thread.sleep(times);
countDownLatch.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
圖解
使用await()提前結束操作
package com.github.gleans;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
public class TestCountDownLatch {
public static void main(String[] args) throws InterruptedException {
CountDownLatch latch = new CountDownLatch(3);
new KeyPass(2000L, "公司一", latch).start();
new KeyPass(3000L, "公司二", latch).start();
new KeyPass(5000L, "公司三", latch).start();
latch.await(2, TimeUnit.SECONDS);
System.out.println("~~~賈總PPT巡演~~~~");
System.out.println("~~~~融資完成，撒花~~~~");
}
static class KeyPass extends Thread {
private long times;
private CountDownLatch countDownLatch;
public KeyPass(long times, String name, CountDownLatch countDownLatch) {
super(name);
this.times = times;
this.countDownLatch = countDownLatch;
}
@Override
public void run() {
try {
Thread.sleep(times);
System.out.println("負責人：" + Thread.currentThread().getName()
+ "開始工作，持續(xù)時間：" + this.times / 1000 + "秒");
countDownLatch.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
假設公司一、公司二、公司三各需要2s、3s、5s來完成工作，賈總等不了，只能等2s，那么就設置await的超時時間
latch.await(2, TimeUnit.SECONDS);
執(zhí)行結果
負責人：公司一開始工作，持續(xù)時間：2秒
~~~賈總PPT巡演~~~~
~~~~融資完成，撒花~~~~
負責人：公司二開始工作，持續(xù)時間：3秒
負責人：公司三開始工作，持續(xù)時間：5秒
方法描述
總結
這個操作可以說是簡單好用，目前還未遇見副作用，若是有大佬，可以告知弟弟一下，提前表示感謝~
到此這篇關于Java騷操作之CountDownLatch的文章就介紹到這了,更多相關Java CountDownLatch內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
這篇文章主要給大家介紹了關于Java如何優(yōu)雅的實現(xiàn)微信登錄注冊的相關資料,文中通過實例代碼介紹的非常詳細,對大家學習或者使用java具有一定的參考學習價值,需要的朋友可以參考下2022-02-02
這篇文章主要介紹了Java接口異步調(diào)用，下面我們來一起學習一下吧2019-05-05
函數(shù)式接口有且僅有一個抽象方法,但是可以有多個非抽象方法的接口,函數(shù)式接口可以被隱式轉換為lambda表達式,這篇文章主要介紹了Java基礎之lambda表達式（JDK1.8新特性）,需要的朋友可以參考下2023-08-08
項目的數(shù)據(jù)庫密碼、redis 密碼等明文展示在配置文件中會有潛在的風險,因此采用合適的安全防護措施是有必要的,下面小編就為大家介紹一下SpringBoot中配置文件加密的方法,希望對大家有所幫助2023-11-11
這篇文章主要介紹了Java中的事件處理與異常處理機制,講解Java是如何對事件或者異常作出響應以及定義異常的一些方法,需要的朋友可以參考下2016-01-01
SpringBoot JVM參數(shù)調(diào)優(yōu)方式
這篇文章主要介紹了SpringBoot JVM參數(shù)調(diào)優(yōu)方式，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-09-09
在 Java 中，允許一個類的定義位于另一個類的內(nèi)部，前者稱為內(nèi)部類，后者稱為外部類。這篇文章將總結一下內(nèi)部類的使用，感興趣的可以了解一下2022-10-10
Spring?Cloud微服務架構Sentinel數(shù)據(jù)雙向同步
這篇文章主要為大家介紹了Spring?Cloud微服務架構Sentinel數(shù)據(jù)雙向同步示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-10-10
本文主要介紹了Mybatis-Plus如何配置分頁對象，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-08-08
這篇文章主要介紹了springboot日期轉換器實現(xiàn)實例解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-12-12