パッケージ org.springframework.messaging.simp.config

クラス TaskExecutorRegistration

java.lang.ObjectSE
org.springframework.messaging.simp.config.TaskExecutorRegistration
public class TaskExecutorRegistration extends ObjectSE
ThreadPoolTaskExecutor のプロパティをカスタマイズするための登録クラス。
導入:
4.0
作成者:
Rossen Stoyanchev, Juergen Hoeller

  • コンストラクターの詳細

    • TaskExecutorRegistration

      public TaskExecutorRegistration()
      デフォルト ThreadPoolTaskExecutor の新しい TaskExecutorRegistration を作成します。

    • TaskExecutorRegistration

      public TaskExecutorRegistration(ThreadPoolTaskExecutor taskExecutor)
      指定された ThreadPoolTaskExecutor の新しい TaskExecutorRegistration を作成します。
      パラメーター:
      taskExecutor - 使用するエグゼキュータ

  • メソッドの詳細

    • corePoolSize

      public TaskExecutorRegistration corePoolSize(int corePoolSize)
      ThreadPoolExecutor のコアプールサイズを設定します。

      注意 : コアプールサイズは、無制限の queueCapacity が構成されている場合の実質的に最大プールサイズです（デフォルト）。これは本質的に、ThreadPoolExecutorSE で説明されている「無制限のキュー」戦略です。この戦略を使用する場合、maxPoolSize は無視されます。

      デフォルトでは、これは Runtime.availableProcessors() の値の 2 倍に設定されています。タスクが頻繁にブロックされないアプリケーションでは、その数は使用可能な CPU/ コアの数に近いか等しい必要があります。

    • maxPoolSize

      public TaskExecutorRegistration maxPoolSize(int maxPoolSize)
      ThreadPoolExecutor の最大プールサイズを設定します。

      注意 : 無制限の queueCapacity が構成されている場合（デフォルト）、最大プールサイズは事実上無視されます。詳細については、ThreadPoolExecutorSE の「無制限キュー」戦略を参照してください。

      デフォルトでは、これは Integer.MAX_VALUE に設定されています。

    • keepAliveSeconds

      public TaskExecutorRegistration keepAliveSeconds(int keepAliveSeconds)
      スレッドが終了する前にアイドル状態を維持できる時間制限を設定します。現在プールにあるスレッドのコア数を超える場合、タスクを処理せずにこの時間待機した後、余分なスレッドは終了します。これは、コンストラクターで設定された値をオーバーライドします。

      デフォルトでは、これは 60 に設定されています。

    • queueCapacity

      public TaskExecutorRegistration queueCapacity(int queueCapacity)
      ThreadPoolExecutor のキュー容量を設定します。

      注意 : 無制限の queueCapacity が構成されている場合（デフォルト）、コアプールサイズは事実上最大プールサイズです。これは本質的に、ThreadPoolExecutorSE で説明されている「無制限のキュー」戦略です。この戦略を使用する場合、maxPoolSize は無視されます。

      デフォルトでは、これは Integer.MAX_VALUE に設定されています。

    • getTaskExecutor

      protected ThreadPoolTaskExecutor getTaskExecutor()