場景：需要啟動多線程處理事情，而在所有事情做完之后，需要修改系統(tǒng)狀態(tài)；那么如何判斷所有線程（事情）都做完了呢？這就需要判斷所有當前運行的線程狀態(tài)了。
代碼 import?java.util.concurrent.CountDownLatch;
import?java.util.concurrent.Executor;
import?java.util.concurrent.Executors;

/** 測試監(jiān)控類?*/
public?class?WatchThread?{

????/**?測試函數(shù) */
????public?void?testThread()?throws?InterruptedException?{
????????int?threadNum?=?10;
????????//?初始化countDown
????????CountDownLatch?threadSignal?=?new?CountDownLatch(threadNum);
????????//?創(chuàng)建固定長度的線程池
????????Executor?executor?=?Executors.newFixedThreadPool(threadNum);
????????for?(int?i?=?0;?i?<?threadNum;?i++)?{?//?開threadNum個線程
????????????Runnable?task?=?new?TestThread(threadSignal);
????????????//?執(zhí)行
????????????executor.execute(task);
????????}
????????threadSignal.await();?//?等待所有子線程執(zhí)行完
????????//?do?work
????????System.out.println(Thread.currentThread().getName()?+?"+++++++結(jié)束.");
????}

????/**?測試函數(shù)?*/
????public?static?void?main(String[]?args)?throws?InterruptedException?{
????????WatchThread?test?=?new?WatchThread();
????????test.testThread();
????}
????private?class?TestThread?implements?Runnable?{
????????private?CountDownLatch?threadsSignal;

????????public?TestThread(CountDownLatch?threadsSignal)?{
????????????this.threadsSignal?=?threadsSignal;
????????}

????????public?void?run()?{
????????????System.out.println(Thread.currentThread().getName()?+?"開始...");
????????????//?do?shomething
????????????System.out.println("開始了線程：：：："?+?threadsSignal.getCount());
????????????//?線程結(jié)束時計數(shù)器減1
????????????threadsSignal.countDown();
????????????System.out.println(Thread.currentThread().getName()?+?"結(jié)束.?還有"
????????????????????+?threadsSignal.getCount()?+?"?個線程");
????????}
????}

}

?

轉(zhuǎn)載于:https://www.cnblogs.com/MyFavorite/archive/2010/10/15/1852567.html

總結(jié)

以上是生活随笔為你收集整理的java监控多个线程的实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。