クラス ThreadPoolTaskExecutor

メソッドの詳細

• setCorePoolSize

  public void setCorePoolSize(int corePoolSize)

  ThreadPoolExecutor のコアプールサイズを設定します。デフォルトは 1 です。

  この設定は、JMX などを介して実行時に変更できます。

• getCorePoolSize

  public int getCorePoolSize()

  ThreadPoolExecutor のコアプールサイズを返します。

• setMaxPoolSize

  public void setMaxPoolSize(int maxPoolSize)

  ThreadPoolExecutor の最大プールサイズを設定します。デフォルトは Integer.MAX_VALUE です。

  この設定は、JMX などを介して実行時に変更できます。

• getMaxPoolSize

  public int getMaxPoolSize()

  ThreadPoolExecutor の最大プールサイズを返します。

• setKeepAliveSeconds

  public void setKeepAliveSeconds(int keepAliveSeconds)

  ThreadPoolExecutor のキープアライブ秒数を設定します。

  デフォルトは 60 です。

  この設定は、JMX などを介して実行時に変更できます。

• getKeepAliveSeconds

  public int getKeepAliveSeconds()

  ThreadPoolExecutor のキープアライブ秒数を返します。

• setQueueCapacity

  public void setQueueCapacity(int queueCapacity)

  ThreadPoolExecutor の BlockingQueue の容量を設定します。

  デフォルトは Integer.MAX_VALUE です。

  正の値は、LinkedBlockingQueue インスタンスにつながります。その他の値は、SynchronousQueue インスタンスにつながります。

  関連事項:

  • LinkedBlockingQueueSE
  • SynchronousQueueSE

• getQueueCapacity

  public int getQueueCapacity()

  ThreadPoolExecutor の BlockingQueue の容量を返します。

  導入:

  5.3.21

  関連事項:

  • setQueueCapacity(int)

• setAllowCoreThreadTimeOut

  public void setAllowCoreThreadTimeOut(boolean allowCoreThreadTimeOut)

  コアスレッドのタイムアウトを許可するかどうかを指定します。これにより、ゼロ以外のキューと組み合わせても動的な拡大と縮小が可能になります（最大プールサイズはキューがいっぱいになると拡大するため）。

  デフォルトは「false」。

  関連事項:

  • ThreadPoolExecutor.allowCoreThreadTimeOut(boolean)SE

• setPrestartAllCoreThreads

  public void setPrestartAllCoreThreads(boolean prestartAllCoreThreads)

  すべてのコアスレッドを開始して、アイドル状態で作業を待機させるかどうかを指定します。

  デフォルトは「false」。

  導入:

  5.3.14

  関連事項:

  • ThreadPoolExecutor.prestartAllCoreThreads()

• setTaskDecorator

  public void setTaskDecorator(TaskDecorator taskDecorator)

  実行しようとしている RunnableSE に適用するカスタム TaskDecorator を指定します。

  このようなデコレータは、必ずしもユーザー提供の Runnable/Callable に適用されるのではなく、実際の実行コールバック（ユーザー提供のタスクのラッパーである可能性があります）に適用されることに注意してください。

  主な使用例は、タスクの呼び出しの周囲に実行コンテキストを設定するか、タスク実行の監視 / 統計を提供することです。

  注意 : TaskDecorator 実装での例外処理は、execute 呼び出しによる単純な Runnable 実行に制限されています。#submit 呼び出しの場合、公開された Runnable は、例外を伝搬しない FutureTask になります。例外を評価するには、キャストして Future#get を呼び出す必要がある場合があります。このような Future ケースで例外にアクセスする方法の例については、ThreadPoolExecutor#afterExecute javadoc を参照してください。

  導入:

  4.3

• initializeExecutor

  protected ExecutorServiceSE initializeExecutor(ThreadFactorySE threadFactory, RejectedExecutionHandlerSE rejectedExecutionHandler)

  メモ: このメソッドは、ExecutorServiceSE をその基本クラスに公開しますが、実際の ThreadPoolExecutorSE ハンドルを内部に保存します。このメソッドをオーバーライドして、executor を置き換えるのではなく、単に ExecutorService ハンドルを装飾したり、カスタム状態を保管したりしてください。

  次で指定:

  クラス ExecutorConfigurationSupport の initializeExecutor 

  パラメーター:

  threadFactory - 使用する ThreadFactory

  rejectedExecutionHandler - 使用する RejectedExecutionHandler

  戻り値:

  新しい ExecutorService インスタンス

  関連事項:

  • ExecutorConfigurationSupport.afterPropertiesSet()

• createQueue

  protected BlockingQueueSE<RunnableSE> createQueue(int queueCapacity)

  BlockingQueue を作成して、ThreadPoolExecutor に使用します。

  正の容量値に対して LinkedBlockingQueue インスタンスが作成されます。SynchronousQueue その他。

  パラメーター:

  queueCapacity - 指定されたキュー容量

  戻り値:

  BlockingQueue インスタンス

  関連事項:

  • LinkedBlockingQueueSE
  • SynchronousQueueSE

• getThreadPoolExecutor

  public ThreadPoolExecutorSE getThreadPoolExecutor() throws IllegalStateExceptionSE

  ネイティブアクセスの基になる ThreadPoolExecutor を返します。

  戻り値:

  基になる ThreadPoolExecutor (非 null)

  例外:

  IllegalStateExceptionSE - ThreadPoolTaskExecutor がまだ初期化されていない場合

• getPoolSize

  public int getPoolSize()

  現在のプールサイズを返します。

  関連事項:

  • ThreadPoolExecutor.getPoolSize()

• getQueueSize

  public int getQueueSize()

  現在のキューサイズを返します。

  導入:

  5.3.21

  関連事項:

  • ThreadPoolExecutor.getQueue()

• getActiveCount

  public int getActiveCount()

  現在アクティブなスレッドの数を返します。

  関連事項:

  • ThreadPoolExecutor.getActiveCount()

• execute

  public void execute(RunnableSE task)

  インターフェースからコピーされた説明: TaskExecutor

  指定された task を実行します。

  実装が非同期実行戦略を使用している場合、呼び出しはすぐに戻るか、同期実行の場合はブロックする可能性があります。

  次で指定:

  インターフェース ExecutorSE の executeSE 

  次で指定:

  インターフェース TaskExecutor の execute 

  パラメーター:

  task - 実行する Runnable (非 null)

• execute

  @DeprecatedSE public void execute(RunnableSE task, long startTimeout)

  使用すべきではありません。

  インターフェースからコピーされた説明: AsyncTaskExecutor

  指定された task を実行します。

  次で指定:

  インターフェース AsyncTaskExecutor の execute 

  パラメーター:

  task - 実行する Runnable (非 null)

  startTimeout - タスクが開始される予定の期間（ミリ秒）。これはエグゼキューターへのヒントとして意図されており、即時タスクの優先処理を可能にします。一般的な値は AsyncTaskExecutor.TIMEOUT_IMMEDIATE または AsyncTaskExecutor.TIMEOUT_INDEFINITE（TaskExecutor.execute(Runnable) で使用されるデフォルト）です。

  関連事項:

  • TaskExecutor.execute(Runnable)

• submit

  public FutureSE<?> submit(RunnableSE task)

  インターフェースからコピーされた説明: AsyncTaskExecutor

  実行可能な Runnable タスクを送信し、そのタスクを表す Future を受け取ります。Future は完了時に null の結果を返します。

  次で指定:

  インターフェース AsyncTaskExecutor の submit 

  パラメーター:

  task - 実行する Runnable (非 null)

  戻り値:

  タスクの保留中の完了を表す Future

• submit

  public <T> FutureSE<T> submit(CallableSE<T> task)

  インターフェースからコピーされた説明: AsyncTaskExecutor

  Callable タスクを送信して実行し、そのタスクを表す Future を受け取ります。Future は、完了時に Callable の結果を返します。

  次で指定:

  インターフェース AsyncTaskExecutor の submit 

  パラメーター:

  task - 実行する Callable (非 null)

  戻り値:

  タスクの保留中の完了を表す Future

• submitListenable

  public ListenableFuture<?> submitListenable(RunnableSE task)

  インターフェースからコピーされた説明: AsyncListenableTaskExecutor

  Runnable タスクを実行のために送信し、そのタスクを表す ListenableFuture を受け取ります。Future は完了時に null の結果を返します。

  次で指定:

  インターフェース AsyncListenableTaskExecutor の submitListenable 

  パラメーター:

  task - 実行する Runnable (非 null)

  戻り値:

  保留中のタスクの完了を表す ListenableFuture 

• submitListenable

  public <T> ListenableFuture<T> submitListenable(CallableSE<T> task)

  インターフェースからコピーされた説明: AsyncListenableTaskExecutor

  Callable タスクを実行のために送信し、そのタスクを表す ListenableFuture を受け取ります。Future は、完了時に Callable の結果を返します。

  次で指定:

  インターフェース AsyncListenableTaskExecutor の submitListenable 

  パラメーター:

  task - 実行する Callable (非 null)

  戻り値:

  保留中のタスクの完了を表す ListenableFuture 

• cancelRemainingTask

  protected void cancelRemainingTask(RunnableSE task)

  クラスからコピーされた説明: ExecutorConfigurationSupport

  ExecutorService.shutdownNow() から返された、実行を開始していない指定された残りのタスクをキャンセルします。

  オーバーライド:

  クラス ExecutorConfigurationSupport の cancelRemainingTask 

  パラメーター:

  task - キャンセルするタスク (通常、RunnableFutureSE )

  関連事項:

  • ExecutorConfigurationSupport.shutdown()
  • Future.cancel(boolean)SE