溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶(hù)服務(wù)條款》

Java線(xiàn)程池運(yùn)行狀態(tài)監(jiān)控實(shí)現(xiàn)解析

發(fā)布時(shí)間：2020-09-25 19:43:49 來(lái)源：腳本之家 閱讀：114 作者：lshan 欄目：編程語(yǔ)言

在實(shí)際開(kāi)發(fā)過(guò)程中，在線(xiàn)程池使用過(guò)程中可能會(huì)遇到各方面的故障，如線(xiàn)程池阻塞，無(wú)法提交新任務(wù)等。

如果你想監(jiān)控某一個(gè)線(xiàn)程池的執(zhí)行狀態(tài)，線(xiàn)程池執(zhí)行類(lèi) ThreadPoolExecutor 也給出了相關(guān)的 API, 能實(shí)時(shí)獲取線(xiàn)程池的當(dāng)前活動(dòng)線(xiàn)程數(shù)、正在排隊(duì)中的線(xiàn)程數(shù)、已經(jīng)執(zhí)行完成的線(xiàn)程數(shù)、總線(xiàn)程數(shù)等。

總線(xiàn)程數(shù) = 排隊(duì)線(xiàn)程數(shù) + 活動(dòng)線(xiàn)程數(shù) + 執(zhí)行完成的線(xiàn)程數(shù)。

線(xiàn)程池使用示例:

private static ExecutorService es = new ThreadPoolExecutor(50, 100, 0L, TimeUnit.MILLISECONDS,
    new LinkedBlockingQueue<Runnable>(100000));
 
public static void main(String[] args) throws Exception {
  for (int i = 0; i < 100000; i++) {
    es.execute(() -> {
      System.out.print(1);
      try {
        Thread.sleep(1000);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    });
  }
 
  ThreadPoolExecutor tpe = ((ThreadPoolExecutor) es);
 
  while (true) {
    System.out.println();
 
    int queueSize = tpe.getQueue().size();
    System.out.println("當(dāng)前排隊(duì)線(xiàn)程數(shù)：" + queueSize);
 
    int activeCount = tpe.getActiveCount();
    System.out.println("當(dāng)前活動(dòng)線(xiàn)程數(shù)：" + activeCount);
 
    long completedTaskCount = tpe.getCompletedTaskCount();
    System.out.println("執(zhí)行完成線(xiàn)程數(shù)：" + completedTaskCount);
 
    long taskCount = tpe.getTaskCount();
    System.out.println("總線(xiàn)程數(shù)：" + taskCount);
 
    Thread.sleep(3000);
  }
 
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持億速云。

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手