Javaでスレッドプールを作成するコードの書き方

2年 ago
光, 明
1 minute

Javaでスレッドプールを作成するコードは、以下の手順で行うことができます。

  1. 関連のクラスおよびパッケージをインポートします。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
  1. スレッドプールオブジェクトを作成します。
ExecutorService executor = Executors.newFixedThreadPool(5);

Executors.newFixedThreadPool()メソッドを使い、スレッドの固定サイズのプールを作成し、このスレッドプールでスレッドの数を5にするために、パラメーターとして5を与えます。

  1. Runnableインタフェースを実装するタスククラスを定義します。
class MyTask implements Runnable {
    public void run() {
        // 执行任务逻辑
    }
}
  1. スレッドプールにタスクを投入する
executor.submit(new MyTask());

submit()メソッドでタスクをスレッドプールに投げて実行している。

  1. スレッドプールをシャットダウンする
executor.shutdown();

タスクの実行完了後に、shutdown()メソッドを呼び出してスレッドプールを終了します。

完全なサンプルコードは次の通りです。

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

class MyTask implements Runnable {
    public void run() {
        // 执行任务逻辑
    }
}

public class ThreadPoolExample {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(5);
        for (int i = 0; i < 10; i++) {
            executor.submit(new MyTask());
        }
        executor.shutdown();
    }
}
bannerAds