Java 判斷線程池所有任務(wù)是否執(zhí)行完畢的操作
我就廢話不多說了,大家還是直接看代碼吧~
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ì)直接打印:“結(jié)束了”。不能達(dá)到我們想要的效果。
通過while(true)循環(huán)判斷exe.isTerminated()的值,為了防止過多的判斷浪費(fèi)資源,可設(shè)置線程睡眠Thread.sleep(200);正是由于這個(gè)睡眠,所以當(dāng)所有線程池中的線程都執(zhí)行完后,有可能延遲200ms才執(zhí)行'結(jié)束了'語句。這個(gè)參數(shù)越小延遲越小,結(jié)果越準(zhǔn)確。
下面是子線程,子線程只是簡(jiǎn)單的將數(shù)字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 代表可以訪問,
如果是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í)行完畢的操作就是小編分享給大家的全部內(nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. 如何通過eclipse web項(xiàng)目導(dǎo)入itellij idea并啟動(dòng)2. jsp實(shí)現(xiàn)登錄界面3. PHP未來的一些可能4. IDEA 端口占用的解決方法(推薦)5. 刪除docker里建立容器的操作方法6. 關(guān)于在IDEA中SpringBoot項(xiàng)目中activiti工作流的使用詳解7. 使用vue寫一個(gè)翻頁的時(shí)間插件實(shí)例代碼8. python 服務(wù)器運(yùn)行代碼報(bào)錯(cuò)ModuleNotFoundError的解決辦法9. 使用IDEA編寫jsp時(shí)EL表達(dá)式不起作用的問題及解決方法10. 將Git存儲(chǔ)庫克隆到本地IntelliJ IDEA項(xiàng)目中的詳細(xì)教程
