Java線程池：ExecutorService，Executors

簡單的Java線程池可以從Executors.newFixedThreadPool( int n)獲得。此方法返回一個線程容量為n的線程池。然後ExecutorService的execute執行之。

現給出一個示例。

package zhangphil.executorservice;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ZhangPhilExecutorService {

 // 為了容易理解線程池的概念，假設容量只有2的線程池。
 // 實際使用過程中當然可以更多！
 private final int NUMBER = 2;

 public ZhangPhilExecutorService() {
  // 創建容量為2的線程池。
  ExecutorService pool = Executors.newFixedThreadPool(NUMBER);

  for (int i = 0; i < 10; i++) {
   Thread t = new TestThread(i);
   System.out.println("線程池執行線程id:" + i);
   pool.execute(t);
  }

  // 關閉線程池。
  pool.shutdown();
 }

 private class TestThread extends Thread {

  private int id;

  public TestThread(int id) {
   this.id = id;
  }

  @Override
  public void run() {

   System.out.println("線程:" + id + " -> 運行...");

   try {
    Thread.sleep(5000);
   } catch (Exception e) {
    e.printStackTrace();
   }

   System.out.println("線程:" + id + " -> 結束!");
  }
 }

 public static void main(String[] args) {
  new ZhangPhilExecutorService();
 }
}

運行的輸出結果：

線程池執行線程id:0
線程池執行線程id:1
線程池執行線程id:2
線程池執行線程id:3
線程:0 -> 運行...
線程池執行線程id:4
線程:1 -> 運行...
線程池執行線程id:5
線程池執行線程id:6
線程池執行線程id:7
線程池執行線程id:8
線程池執行線程id:9
線程:1 -> 結束!
線程:0 -> 結束!
線程:2 -> 運行...
線程:3 -> 運行...
線程:3 -> 結束!
線程:2 -> 結束!
線程:4 -> 運行...
線程:5 -> 運行...
線程:4 -> 結束!
線程:5 -> 結束!
線程:6 -> 運行...
線程:7 -> 運行...
線程:7 -> 結束!
線程:6 -> 結束!
線程:8 -> 運行...
線程:9 -> 運行...
線程:9 -> 結束!
線程:8 -> 結束!