Javaのスレッドプールとは？仕組みと実装例をわかりやすく解説

スレッドプールとは

スレッドプール（Thread Pool）とは、あらかじめ初期化された複数のスレッドをまとめて管理する仕組みのことです。基本的な考え方は、アプリケーションの起動時に一定数のスレッドを作成してプールに入れておき、それらのスレッドが仕事を待機するというものです。

サーバーがリクエストを受け取ると、利用可能なスレッドがあればプールから1つ取り出して処理を任せます。スレッドはタスクの完了後、破棄されることなくプールへ戻り、次の仕事を待ちます。もしプール内に空きスレッドが存在しない場合は、空きができるまでサーバー側で待機することになります。

スレッドプールのメリット

• タスクごとに新しいスレッドを生成する必要がないため、スレッド作成のコスト（時間・リソース）を節約できる
• ServletやJSPでは、コンテナがリクエスト処理のために内部でスレッドプールを利用している

このように、スレッドプールは大量のリクエストを効率的にさばくために欠かせない技術です。

サンプルコード

ここでは、ExecutorService と Executors を使ったシンプルなスレッドプールの実装例を紹介します。

EmployeeThread.java

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

class EmployeeThread implements Runnable {
    private String message;

    public EmployeeThread(String s) {
        this.message = s;
    }

    public void run() {
        System.out.println(Thread.currentThread().getName() + " (Start) message = " + message);
        processmessage(); // スレッドを1秒間スリープさせるメソッドを呼び出し
        System.out.println(Thread.currentThread().getName() + " (End)"); // スレッド名を出力
    }

    private void processmessage() {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

このクラスは Runnable を実装しており、run() メソッド内でタスクの開始・終了を出力します。processmessage() では Thread.sleep(1000) によって1秒間の処理待ちをシミュレートしています。

ExampleThreadPool.java

public class ExampleThreadPool {
    public static void main(String[] args) {
        // 6つのスレッドを持つ固定サイズのプールを作成
        ExecutorService executor = Executors.newFixedThreadPool(6);

        for (int i = 0; i < 6; i++) {
            Runnable worker = new EmployeeThread("" + i);
            executor.execute(worker); // ExecutorServiceのexecuteメソッドでタスクを投入
        }

        executor.shutdown(); // 新規タスクの受付を停止
        while (!executor.isTerminated()) { } // 全タスク完了まで待機

        System.out.println("Finished all the threads");
    }
}

コードのポイント

• Executors.newFixedThreadPool(6)：6つのスレッドを持つ固定サイズのスレッドプールを生成します。
• execute(worker)：ExecutorService の execute() メソッドでタスクをプールに投入します。空きスレッドが順次タスクを引き受けます。
• shutdown()：新規タスクの受け付けを停止します。すでに投入済みのタスクは最後まで実行されます。
• isTerminated()：すべてのタスクが完了したかどうかを判定し、完了するまでループで待機します。

このプログラムを実行すると、6つのワーカースレッドが並行してタスクを処理し、それぞれの開始・終了がコンソールに出力されます。すべての処理が完了すると「Finished all the threads」が表示されます。