「Java」スレッド・プールThreadPoolExecutor状態変更方法

2022年5月10日

環境
JavaSE1.8
Eclipse 2019

関数
public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue)

指定された初期パラメータ、およびデフォルトのスレッド・ファクトリと拒否された実行ハンドラを使用して、
新しいThreadPoolExecutorを作成します。この汎用コンストラクタの代わりに、Executorsファクトリ・メソッドのいずれかを使用する方が便利な場合があります。

パラメータについて

corePoolSize
allowCoreThreadTimeOutが設定されていないかぎり、アイドルであってもプール内に維持されるスレッドの数
maximumPoolSize
プール内で可能なスレッドの最大数
keepAliveTime
スレッドの数がコアよりも多い場合、これは超過したアイドル状態のスレッドが新しいタスクを待機してから終了するまでの最大時間。
unit
keepAliveTime引数の時間単位
workQueue
タスクが実行されるまで保持するために使用するキュー。このキューは、executeメソッドで送信されたRunnableタスクだけを保持する。

shutdown()
順序正しくシャットダウンを開始します。以前に送信されたタスクが実行されますが、新規タスクは受け入れられません。

terminated()
executorが終了したときに呼び出されるメソッドです。

使用例

package com.arkgame.study;

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

public class ThreadPoolDemo {

      public static void main(String[] args) {
            // スレッドプールを作成する
            ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.SECONDS,
                        new LinkedBlockingQueue<>(100)) {
                  @Override
                  protected void terminated() {
                        // executorが終了したときに呼び出されるメソッド
                        super.terminated();
                        System.out.println("terminated()メソッドを実行しています");
                  }
            };
            // executorがシャットダウン
            threadPool.shutdown();
            // スレッドプールの実行が終了するのを待つ
            try {
                  while (!threadPool.awaitTermination(1, TimeUnit.SECONDS)) {
                        System.out.println("スレッドプールが実行されています");
                  }
            } catch (InterruptedException e) {
                  e.printStackTrace();
            }

      }

}

実行結果
terminated()メソッドを実行しています