生活随笔
收集整理的這篇文章主要介紹了
测试并发应用（三）监控Executor框架
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
聲明：本文是《 Java 7 Concurrency Cookbook 》的第八章， 作者： Javier Fernández González 譯者：鄭玉婷
監(jiān)控Executor框架
Executor 框架提供從線程的創(chuàng)建和管理來分別實現任務來執(zhí)行這些任務的機制。如果你使用一個執(zhí)行者，你只需要實現 Runnable 對象并把他們發(fā)送給執(zhí)行者。 執(zhí)行者的責任是管理線程。當你發(fā)一個任務給執(zhí)行者，它會嘗試使用pooled線程來執(zhí)行這個任務，來避免創(chuàng)建新的任務。此機制由 Executor 接口提供，它是以 ThreadPoolExecutor 類來實現的。
在這個指南，你將學習從ThreadPoolExecutor執(zhí)行者可以獲取的信息和如何獲取這些信息。
準備
指南中的例子是使用Eclipse IDE 來實現的。如果你使用Eclipse 或者其他的IDE，例如NetBeans, 打開并創(chuàng)建一個新的java項目。
怎么做呢…
按照這些步驟來實現下面的例子：:
| 01 | //1. 創(chuàng)建一個類，名為 Task，并實現 Runnable 接口. |
| 02 | public class Task implements Runnable { |
| 04 | //2. 聲明一個私有 long 屬性，名為 milliseconds. |
| 05 | private long milliseconds; |
| 08 | public Task (long milliseconds) { |
| 09 | this.milliseconds=milliseconds; |
| 12 | //4. 實現 run() 方法。通過 milliseconds 屬性讓線程進入一段時間休眠。 |
| 15 | System.out.printf("%s: Begin\n",Thread.currentThread(). getName()); |
| 17 | TimeUnit.MILLISECONDS.sleep(milliseconds); |
| 18 | } catch (InterruptedException e) { |
| 21 | System.out.printf("%s: End\n",Thread.currentThread(). getName()); |
| 24 | //5. 創(chuàng)建例子的主類通過創(chuàng)建一個類，名為 Main 并添加 main()方法。 |
| 27 | public static void main(String[] args) throws Exception { |
| 29 | //6. 使用Executors類的newCachedThreadPool()方法創(chuàng)建新的 Executor 對象。 |
| 30 | ThreadPoolExecutor executor = (ThreadPoolExecutor)Executors. newCachedThreadPool(); |
| 32 | //7. 創(chuàng)建并提交10個 Task 對象給執(zhí)行者。用隨機數字初始化任務。 |
| 33 | Random random=new Random(); |
| 34 | for (int i=0; i<10; i++) { |
| 35 | Task task=new Task(random.nextInt(10000)); |
| 39 | //8. 創(chuàng)建迭代為5的for循環(huán)。在每步，傳遞執(zhí)行者調用 showLog() 方法寫相關信息，并讓線程休眠1秒。 |
| 40 | for (int i=0; i<5; i++){ |
| 42 | TimeUnit.SECONDS.sleep(1); |
| 45 | //9. 使用 shutdown() 方法關閉執(zhí)行者。 |
| 48 | //10. 另創(chuàng)建迭代為5的for循環(huán)。在每步，傳遞執(zhí)行者調用 showLog() 方法寫相關信息，并讓線程休眠1秒。 |
| 49 | for (int i=0; i<5; i++){ |
| 51 | TimeUnit.SECONDS.sleep(1); |
| 54 | //11. 使用 awaitTermination() 方法等待執(zhí)行者的終結。 |
| 55 | executor.awaitTermination(1, TimeUnit.DAYS); |
| 58 | System.out.printf("Main: End of the program.\n"); |
| 61 | //13. 實現 showLog() 方法，接收 Executor 作為參數。寫關于pool的大小，任務的數量，和執(zhí)行者狀態(tài)的信息。 |
| 62 | private static void showLog(ThreadPoolExecutor executor) { |
| 63 | System.out.printf("*********************"); |
| 64 | System.out.printf("Main: Executor Log"); |
| 65 | System.out.printf("Main: Executor: Core Pool Size:%d\n",executor.getCorePoolSize()); |
| 66 | System.out.printf("Main: Executor: Pool Size: %d\n",executor. getPoolSize()); |
| 67 | System.out.printf("Main: Executor: Active Count:%d\n",executor.getActiveCount()); |
| 68 | System.out.printf("Main: Executor: Task Count: %d\n",executor. getTaskCount()); |
| 69 | System.out.printf("Main: Executor: Completed Task Count:%d\n",executor.getCompletedTaskCount()); |
| 70 | System.out.printf("Main: Executor: Shutdown: %s\n",executor. isShutdown()); |
| 71 | System.out.printf("Main: Executor: Terminating:%s\n",executor.isTerminating()); |
| 72 | System.out.printf("Main: Executor: Terminated: %s\n",executor. isTerminated()); |
| 73 | System.out.printf("*********************\n"); |
它是如何工作的…
在這個指南里，你實現了一個任務，它對它的執(zhí)行線程進行了一段隨機毫秒數的阻塞。然后，你發(fā)送10個任務給執(zhí)行者，并且當你正在等待它們的終結的同時，你已經把關于執(zhí)行者的狀態(tài)的信息寫入到操控臺。你使用了以下的方法來獲取 Executor 對象的狀態(tài)：
- getCorePoolSize(): 此方法返回一個int數，表示線程的核心數。它是當執(zhí)行者沒有執(zhí)行任何任務時，在內部線程池的線程數。
- getPoolSize(): 此方法返回一個int數，表示內部線程池的真實大小。
- getActiveCount(): 此方法返回一個int數，表示當前執(zhí)行任務的線程數。
- getTaskCount(): 此方法返回一個long數，表示已經分配執(zhí)行的任務數。
- getCompletedTaskCount(): 此方法返回一個long數，表示已經被這個執(zhí)行者執(zhí)行并結束執(zhí)行的任務數。
- isShutdown(): 當 執(zhí)行的 shutdown() 方法被調用來結束執(zhí)行時，此方法返回 Boolean 值。
- isTerminating(): 當執(zhí)行者正在操作shutdown()，但是還沒結束時，此方法返回 Boolean 值。
- isTerminated(): 當這個執(zhí)行者結束執(zhí)行時，此方法返回 Boolean 值。
總結
以上是生活随笔為你收集整理的测试并发应用（三）监控Executor框架的全部內容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。
