newCachedThreadPool メソッド

別のタイプのスレッド プールは「キャッシュ」です。このようなスレッド プールは、固定スレッド プールと同様に一般的に使用されます。

名前が示すように、この種類のスレッド プールはスレッドをキャッシュします。新しいタスクを実行するためにそれらのスレッドを再利用するために、未使用のスレッドを一定期間存続させます。このようなスレッド プールは、適度な量の軽い作業がある場合に最適です。

「ある程度の妥当な量」の意味はかなり広いですが、そのようなプールはあらゆる数のタスクに適しているわけではないことを知っておく必要があります。たとえば、100 万個のタスクを作成するとします。それぞれにかかる時間が非常に短い場合でも、不当な量のリソースが使用され、パフォーマンスが低下します。また、I/O タスクなど、実行時間が予測できない場合にも、このようなプールを避ける必要があります。

内部では、ThreadPoolExecutorコンストラクターが次の引数を使用して呼び出されます。

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, 
      new SynchronousQueue<Runnable>());
}

次の値が引数としてコンストラクターに渡されます。

また、まったく同じ方法で独自のThreadFactory実装を渡すことができます。

SynchronousQueue について話しましょう

同期転送の基本的な考え方は非常に単純ですが、直感に反しています (つまり、直感や常識からそれは間違っていると判断されます)。別のスレッドがキューで要素を受信した場合にのみ、要素をキューに追加できます。同時。つまり、新しいタスクが到着するとすぐに、実行中のスレッドがすでにそのタスクを選択しているため、同期キューにタスクを含めることはできません。

新しいタスクがキューに入ると、プール内に空いているアクティブなスレッドがあれば、そのタスクが選択されます。すべてのスレッドがビジー状態の場合は、新しいスレッドが作成されます。

キャッシュされたプールはゼロスレッドから始まり、Integer.MAX_VALUEスレッドまで増加する可能性があります。基本的に、キャッシュされたスレッド プールのサイズはシステム リソースによってのみ制限されます。

システム リソースを節約するために、キャッシュされたスレッド プールは 1 分間アイドル状態のスレッドを削除します。

実際にどのように機能するかを見てみましょう。ユーザーリクエストをモデル化するタスククラスを作成します。

public class Task implements Runnable {
   int taskNumber;

   public Task(int taskNumber) {
       this.taskNumber = taskNumber;
   }

   @Override
   public void run() {
       System.out.println("Processed user request #" + taskNumber + " on thread " + Thread.currentThread().getName());
   }
}
    

mainメソッドでは、 newCachedThreadPoolを作成し、実行する 3 つのタスクを追加します。ここではサービスのステータスを出力します(1)。

次に、30 秒間一時停止し、別のタスクを開始して、ステータスを表示します(2)。

その後、メインスレッドを 70 秒間一時停止し、ステータスを出力します(3)。その後、再び 3 つのタスクを追加し、ステータスを再度出力します(4)。

タスクを追加した直後にステータスを表示する場所では、最新の出力を得るために最初に 1 秒間のスリープを追加します。

ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < 3; i++) {
            executorService.submit(new Task(i));
        }
 
        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(1)
 
        TimeUnit.SECONDS.sleep(30);
 
        executorService.submit(new Task(3));
        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(2)
 
        TimeUnit.SECONDS.sleep(70);
 
            System.out.println(executorService);	//(3)
 
        for (int i = 4; i < 7; i++) {
            executorService.submit(new Task(i));
        }
 
        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(4)
        executorService.shutdown();

そして結果は次のとおりです。

それぞれの手順を見てみましょう。

さて、これで、別の種類のエグゼキューター サービスのロジックについて理解できました。

Executorsユーティリティ クラスの他のメソッドと同様に、newCachedThreadPoolメソッドにも、 ThreadFactoryオブジェクトを引数として受け取るオーバーロードされたバージョンがあります。