Java 判斷線程池所有任務(wù)是否執(zhí)行完畢的操作
我就廢話(huà)不多說(shuō)了,大家還是直接看代碼吧~
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class Test { public static void main(String args[]) throws InterruptedException { ExecutorService exe = Executors.newFixedThreadPool(3); for (int i = 1; i <= 5; i++) { exe.execute(new SubThread(i)); } exe.shutdown(); while (true) { if (exe.isTerminated()) { System.out.println("結(jié)束了!"); break; } Thread.sleep(200); } } }
上面是主線程的代碼,創(chuàng)建了一個(gè)能同時(shí)執(zhí)行2個(gè)線程的線程池,并投入5個(gè)線程,當(dāng)5個(gè)線程都執(zhí)行完畢后打印---“結(jié)束了!”字符串。
exe.shutdown();該方法在加入線程隊(duì)列的線程執(zhí)行完之前不會(huì)執(zhí)行。exe.isTerminated()當(dāng)shutdown()或者shutdownNow()執(zhí)行了之后才會(huì)執(zhí)行,并返回true。
在上面的代碼中必須有exe.isTerminated()的判斷,否則在投入5個(gè)線程到線程池后會(huì)直接打?。骸敖Y(jié)束了”。不能達(dá)到我們想要的效果。
通過(guò)while(true)循環(huán)判斷exe.isTerminated()的值,為了防止過(guò)多的判斷浪費(fèi)資源,可設(shè)置線程睡眠Thread.sleep(200);正是由于這個(gè)睡眠,所以當(dāng)所有線程池中的線程都執(zhí)行完后,有可能延遲200ms才執(zhí)行"結(jié)束了"語(yǔ)句。這個(gè)參數(shù)越小延遲越小,結(jié)果越準(zhǔn)確。
下面是子線程,子線程只是簡(jiǎn)單的將數(shù)字i打印出來(lái);
public class SubThread extends Thread{ private final int i; public SubThread(int i){ this.i = i; } @Override public void run(){ System.out.println(i); } }
執(zhí)行結(jié)果:
3
1
4
5
2
結(jié)束了!
成功構(gòu)建 (總時(shí)間: 2 秒)
子線程執(zhí)行順序不能控制,所以輸出的結(jié)果是亂序的。
補(bǔ)充知識(shí):java如何禁掉反射
SecurityManager
有一個(gè)checkMemberAccess這個(gè)方法可以阻止利用反射;
如:
SecurityManager sm = new SecurityManager();
sm.checkMemberAccess(Test.class, Member.PUBLIC);
前面一個(gè)為CLASS,后面需要填一個(gè)INT值,Member.PUBLIC 代表可以訪問(wèn),
如果是PUBLIC,反射可以執(zhí)行,DECLARED,反射運(yùn)行時(shí),會(huì)報(bào)錯(cuò)。
SecurityManager另外一個(gè)例子:
package com.jd.basic.pk.manager; import java.lang.reflect.Field; import java.security.Permission; public class UseReflection { static { try { System.setSecurityManager(new MySecurityManager()); } catch (SecurityException se) { System.out.println("SecurityManager already set!"); } } public static void main(String args[]) { Object prey = new Prey(); try { Field pf = prey.getClass().getDeclaredField("privateString"); pf.setAccessible(true); pf.set(prey, "Aminur test"); System.out.println(pf.get(prey)); } catch (Exception e) { System.err.println("Caught exception " + e.toString()); } } } class Prey { @SuppressWarnings("unused") private String privateString = "privateValue"; } class MySecurityManager extends SecurityManager { public void checkPermission(Permission perm) { if (perm.getName().equals("suppressAccessChecks")) { throw new SecurityException("Can not change the permission dude.!"); } } }
以上這篇Java 判斷線程池所有任務(wù)是否執(zhí)行完畢的操作就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
輕松理解Java面試和開(kāi)發(fā)中的IoC(控制反轉(zhuǎn))
在Java開(kāi)發(fā)中,IoC意 味著將你設(shè)計(jì)好的類(lèi)交給系統(tǒng)去控制,而不是在你的類(lèi)內(nèi)部控制。這稱(chēng)為控制反轉(zhuǎn)。下文給大家介紹Java面試和開(kāi)發(fā)中的IoC(控制反轉(zhuǎn))知識(shí),需要的朋友參考下吧2017-07-07使用maven實(shí)現(xiàn)有關(guān)Jsoup簡(jiǎn)單爬蟲(chóng)的步驟
這篇文章主要介紹了使用maven實(shí)現(xiàn)有關(guān)Jsoup簡(jiǎn)單爬蟲(chóng)的步驟,文中附含詳細(xì)示例代碼,有需要的朋友可以借鑒參考下,希望能夠有所幫助2021-09-09下載遠(yuǎn)程maven倉(cāng)庫(kù)的jar?手動(dòng)放到本地倉(cāng)庫(kù)詳細(xì)操作
這篇文章主要介紹了如何下載遠(yuǎn)程maven倉(cāng)庫(kù)的jar?手動(dòng)放到本地倉(cāng)庫(kù),本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-03-03OpenFeign實(shí)現(xiàn)攜帶請(qǐng)求頭方案詳細(xì)介紹
這篇文章主要介紹了OpenFeign實(shí)現(xiàn)攜帶請(qǐng)求頭方案,在通過(guò)???OpenFeign???進(jìn)行服務(wù)調(diào)用的過(guò)程中,我們需要將用戶(hù)的??user-token???、??lang??等信息放入請(qǐng)求header中。在分布式系統(tǒng)中,往往一個(gè)業(yè)務(wù)接口內(nèi)部會(huì)發(fā)生多次RPC調(diào)用2022-11-11Java中JVM的雙親委派、內(nèi)存溢出、垃圾回收和調(diào)優(yōu)詳解
這篇文章主要介紹了Java中JVM的雙親委派、內(nèi)存溢出、垃圾回收和調(diào)優(yōu)詳解,類(lèi)加載器是Java虛擬機(jī)(JVM)的一個(gè)重要組成部分,它的主要作用是將類(lèi)的字節(jié)碼加載到內(nèi)存中,并生成對(duì)應(yīng)的Class對(duì)象,需要的朋友可以參考下2023-07-07基于NIO的Netty網(wǎng)絡(luò)框架(詳解)
下面小編就為大家?guī)?lái)一篇基于NIO的Netty網(wǎng)絡(luò)框架(詳解)。小編覺(jué)得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-06-06mybatis注解如何實(shí)現(xiàn)對(duì)象批量更改
這篇文章主要介紹了mybatis注解實(shí)現(xiàn)對(duì)象批量更改的方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-07-07Java靜態(tài)和非靜態(tài)成員變量初始化過(guò)程解析
這篇文章主要介紹了Java靜態(tài)和非靜態(tài)成員變量初始化過(guò)程解析,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-01-01SpringCloudAlibaba微服務(wù)調(diào)用組件OpenFeign的方法
Feign是Netflix開(kāi)發(fā)的聲明式、模板化的HTTP客戶(hù)端,其靈感來(lái)自Retrofit、JAXRS-2.0以及WebSocket,Feign可幫助我們更加便捷、優(yōu)雅地調(diào)用HTTP API,這篇文章主要介紹了SpringCloudAlibaba微服務(wù)調(diào)用組件OpenFeign,需要的朋友可以參考下2024-07-0710k+點(diǎn)贊的 SpringBoot 后臺(tái)管理系統(tǒng)教程詳解
這篇文章主要介紹了10k+點(diǎn)贊的 SpringBoot 后臺(tái)管理系統(tǒng)教程詳解,本文通過(guò)圖文并茂的形式給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-01-01