国产成人精品亚洲777人妖,欧美日韩精品一区视频,最新亚洲国产,国产乱码精品一区二区亚洲

您的位置:首頁技術文章
文章詳情頁

Java并發編程之閉鎖與柵欄的實現

瀏覽:2日期:2022-09-02 10:52:28

一、前言

閉鎖與柵欄是在多線程編程中的概念,因為在多線程中,我們不能控制線程的執行狀態,所以給線程加鎖,讓其按照我們的想法有秩序的執行。

閉鎖

CountDownLatch,實例化時需要傳入一個int類型的數字(count),意為等待count個線程完成之后才能執行下一步動作。

如今天要做的事情是吃晚飯,再去散步。假設11個人相約晚飯后一起去散步,我們得等11個人全都吃完晚飯了才能出發去散步。簡而言之就是做了才到達某一種狀態。

柵欄

CyclicBarrier,實例化時需要傳入一個int類型的數字(parties),意為等待parties個線程都準備就緒后才能執行自己的任務。

如今天要做的事情是吃晚飯,8個人約好一起去某餐廳吃飯,得等到人齊了才能去吃飯。簡而言之就是到達某種狀態后一起做。

二、實例

閉鎖 CountDownLatch

package com.test; import java.util.ArrayList;import java.util.List;import java.util.concurrent.BrokenBarrierException;import java.util.concurrent.CountDownLatch; public class Test { public static void main(String[] args) { CountDownLatch latch = new CountDownLatch(3); // 模擬三個任務 List<String> jobs = new ArrayList<String>(); jobs.add('first'); jobs.add('second'); jobs.add('third'); // 循環執行任務 for (String job : jobs) { new Thread(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + ' : 進入run方法'); latch.countDown(); System.out.println(Thread.currentThread().getName() + ' : 執行' + job); } }).start(); } try { latch.await(); } catch (InterruptedException e) { e.printStackTrace(); } // 任務都執行完后才執行 System.out.println('回到main線程'); } }

執行結果:

Thread-1 : 進入run方法

Thread-2 : 進入run方法

Thread-2 : 執行third

Thread-0 : 進入run方法

Thread-1 : 執行second

Thread-0 : 執行first

回到main線程

通過執行結果可看出,當所有線程都執行完后才能回到主線程繼續執行后面的輸出。

柵欄 CyclicBarrier

package com.test; import java.util.ArrayList;import java.util.List;import java.util.concurrent.BrokenBarrierException;import java.util.concurrent.CyclicBarrier; public class Test { public static void main(String[] args) { CyclicBarrier barrier = new CyclicBarrier(3); // 模擬創建三個任務 List<String> jobs = new ArrayList<String>(); jobs.add('first'); jobs.add('second'); jobs.add('third'); //循環執行任務 for (String job : jobs) { new Thread(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + ' : 進入run方法'); try { // 等待 barrier.await(); } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + ' : 執行' + job); } }).start(); } } }

執行結果:

Thread-1 : 進入run方法

Thread-2 : 進入run方法

Thread-0 : 進入run方法

Thread-0 : 執行first

Thread-1 : 執行second

Thread-2 : 執行third

通過執行結果可看出,當所有線程都執行都進入到run方法后,才能繼續執行自己內部的方法。

到此這篇關于Java并發編程之閉鎖與柵欄的實現的文章就介紹到這了,更多相關Java 閉鎖與柵欄內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Java
相關文章:
主站蜘蛛池模板: 雷山县| 马公市| 上杭县| 澎湖县| 台东市| 德格县| 吉木乃县| 大邑县| 五台县| 拜城县| 云龙县| 武城县| 额尔古纳市| 团风县| 晋城| 邹平县| 旬邑县| 鸡泽县| 余江县| 苍南县| 乌什县| 宜宾市| 永德县| 大埔县| 商河县| 竹山县| 吉安市| SHOW| 万州区| 平阴县| 潼关县| 明光市| 托里县| 漳浦县| 特克斯县| 绥阳县| 安新县| 西贡区| 延庆县| 涞水县| 任丘市|