ThreadPoolExecutor について(第1部：基本的な使い方)

本当に基本的な使い方を紹介します。

■前提条件
スレッド数:3
スレッド消失時間：500ms
スレッド実行される処理(タスク)はRunnableインタフェースを実装させます。
（Callableインタフェースでもできます(タスクの登録方法がRunnableと若干異なります)）

■実ソース

view plainprint?

1. package sample.thread.basic;  
2.   
3. import java.util.concurrent.BlockingQueue;  
4. import java.util.concurrent.LinkedBlockingQueue;  
5. import java.util.concurrent.ThreadPoolExecutor;  
6. import java.util.concurrent.TimeUnit;  
7.   
8. public class SampleMain {  
9.   
10.  public static void main(final String[] args) {  
11.   new SampleMain().go();  
12.  }  
13.   
14.  public void go() {  
15.   System.out.println("処理開始");  
16.   final BlockingQueue<Runnable%gt; queue = new LinkedBlockingQueue]<Runnable>();  
17.   // queueに事前に積んでおくこともできる  
18.   for (int i = 0; i < 50; i++) {  
19.    queue.add(new TestRunnable());  
20.   }  
21.   final ThreadPoolExecutor tpe = new ThreadPoolExecutor(3, 3, 500, TimeUnit.MILLISECONDS, queue, new ThreadPoolExecutor.CallerRunsPolicy());  
22.   try {  
23.    // shutdown()を呼ぶ前であれば、タスクを後から追加することもできる  
24.    for (int i = 0; i < 50; i++) {  
25.     tpe.execute(new TestRunnable());  
26.    }  
27.   } finally {  
28.    // 必ずshutdownを実行する。実行しないとスレッドが開放されないので処理が一生  
29.    System.out.println("ShutDown実行。");  
30.    tpe.shutdown();  
31.   }  
32.   while (true) {  
33.    if (tpe.isTerminated()) {  
34.     break;  
35.    }  
36.    try {  
37.     System.out.println("タスク終了待ち 1000ms.");  
38.     Thread.currentThread();  
39.     Thread.sleep(1000);  
40.    } catch (InterruptedException ignore) {  
41.    }  
42.   }  
43.   System.out.println("処理終了");  
44.  }  
45.   
46.  /** 
47.   * スレッド実行されるタスク。 
48.   */  
49.  private static class TestRunnable implements Runnable {  
50.   
51.   private static volatile int count = 0;  
52.   
53.   @Override  
54.   public void run() {  
55.    System.out.println(count++);  
56.   }  
57.  }  
58. }  

package sample.thread.basic;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class SampleMain {

 public static void main(final String[] args) {
  new SampleMain().go();
 }

 public void go() {
  System.out.println("処理開始");
  final BlockingQueue<Runnable%gt; queue = new LinkedBlockingQueue]<Runnable>();
  // queueに事前に積んでおくこともできる
  for (int i = 0; i < 50; i++) {
   queue.add(new TestRunnable());
  }
  final ThreadPoolExecutor tpe = new ThreadPoolExecutor(3, 3, 500, TimeUnit.MILLISECONDS, queue, new ThreadPoolExecutor.CallerRunsPolicy());
  try {
   // shutdown()を呼ぶ前であれば、タスクを後から追加することもできる
   for (int i = 0; i < 50; i++) {
    tpe.execute(new TestRunnable());
   }
  } finally {
   // 必ずshutdownを実行する。実行しないとスレッドが開放されないので処理が一生
   System.out.println("ShutDown実行。");
   tpe.shutdown();
  }
  while (true) {
   if (tpe.isTerminated()) {
    break;
   }
   try {
    System.out.println("タスク終了待ち 1000ms.");
    Thread.currentThread();
    Thread.sleep(1000);
   } catch (InterruptedException ignore) {
   }
  }
  System.out.println("処理終了");
 }

 /**
  * スレッド実行されるタスク。
  */
 private static class TestRunnable implements Runnable {

  private static volatile int count = 0;

  @Override
  public void run() {
   System.out.println(count++);
  }
 }
}

■気をつける点
必ずshutdown()メソッドを呼ぶ必要があります！
これを忘れるとMainスレッドが終了してもスレッドだけプーリングされている状態となり、処理が終わりません。
shutdown()メソッドを実行してもすぐに処理が終了するわけではありません。
すべてのスレッドを正常に処理し終えるまでスレッドは開放されません。
すべてのタスクの処理が終わるのを待ちたいのであれば、終了を待つ必要があります。

ThreadPoolExecutor.terminated()をオーバーライドして、終了処理を書くこともできます。


こんな簡単な記述で、スレッドをプーリングすることができます。
次回は、ThreadPoolExecutorをインスタンス化する際に指定できる、いろいろな機能について触れたいと思います。