Java newFixedThreadPool監控當前執行緒的執行狀況
阿新 • • 發佈:2019-02-20
MyThreadPool為執行緒池管理類import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class MyThreadPool { private ExecutorService exe; private static final int POOL_SIZE = 4; public MyThreadPool() { exe = Executors.newFixedThreadPool(POOL_SIZE); } public void doTask() { int i = 0; while (i < 50) { exe.execute(new MyThread(i, exe)); i++; } } class MyThread implements Runnable { int id; ExecutorService exe; MyThread(int id, ExecutorService exe) { this.exe = exe; this.id = id; } public void run() { System.out.println(id + "start"); try { Thread.sleep(5000L); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(id + "pass 5 second"); System.out.println("exe info:" + exe.toString()); try { Thread.sleep(5000L); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(id + "end"); } } public static void main(String[] args) { new MyThreadPool().doTask(); } }
MyThread為實際需要執行的執行緒類
執行log如下(一小部分):
- <span style="font-size:18px;">1start
- 2start
- 3start
- 0start
- 2pass 5 second
- exe info:java.util.concurrent.ThreadPoolExecutor@39890510[Running, pool size = 4, active threads = 4, queued tasks = 46, completed tasks = 0]
-
0pass 5 second
- exe info:java.util.concurrent.ThreadPoolExecutor@39890510[Running, pool size = 4, active threads = 4, queued tasks = 46, completed tasks = 0]
- 3pass 5 second
- exe info:java.util.concurrent.ThreadPoolExecutor@39890510[Running, pool size = 4, active threads = 4, queued tasks = 46, completed tasks = 0]
-
1pass 5 second
- exe info:java.util.concurrent.ThreadPoolExecutor@39890510[Running, pool size = 4, active threads = 4, queued tasks = 46, completed tasks = 0]
- 2end
- 4start
- 0end
- 5start
- 3end
- 6start
- 1end
- 7start
- </span>
可以看到當前在執行的執行緒只有前4個,佇列中有46個任務在等待
只要有一個執行緒結束立即就會執行佇列中的下一個執行緒