ThreadPoolTaskExecutor (Spring Framework 5.0.6.RELEASE API)

java.lang.Object
- org.springframework.util.CustomizableThreadCreator
- - org.springframework.scheduling.concurrent.CustomizableThreadFactory
  - - org.springframework.scheduling.concurrent.ExecutorConfigurationSupport
    - - org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

実装されているすべてのインターフェース:
java.io.Serializable, java.util.concurrent.Executor, java.util.concurrent.ThreadFactory, Aware, BeanNameAware, DisposableBean, InitializingBean, AsyncListenableTaskExecutor, AsyncTaskExecutor, TaskExecutor, SchedulingTaskExecutor
```
public class ThreadPoolTaskExecutor
extends ExecutorConfigurationSupport
implements AsyncListenableTaskExecutor, SchedulingTaskExecutor
```
JavaBean は、ThreadPoolExecutor を Bean スタイルで (その "corePoolSize"、"maxPoolSize"、"keepAliveSeconds"、"queueCapacity" プロパティを介して) 構成し、それを Spring TaskExecutor として公開することを可能にします。このクラスは、管理と監視 (JMX 経由など) にも適しており、いくつかの便利な属性を提供します: "corePoolSize"、"maxPoolSize"、"keepAliveSeconds" (すべて実行時の更新をサポート)、"poolSize"、"activeCount" (イントロスペクションのみ)。
別の方法として、コンストラクターインジェクションを使用して ThreadPoolExecutor インスタンスを直接セットアップするか、Executors クラスを指すファクトリメソッド定義を使用することができます。このような未加工のエグゼキュータを Spring TaskExecutor として公開するには、ConcurrentTaskExecutor アダプターでラップするだけです。
注意 : このクラスは、Spring の TaskExecutor インターフェースと Executor インターフェースを実装します。前者はプライマリインターフェースであり、もう一方はセカンダリの利便性として機能します。このため、例外処理は、特に TaskRejectedException に関して、Executor 契約ではなく TaskExecutor 契約に従います。
代わりにネイティブ ExecutorService 露出を好む場合は、このクラスの代わりに ThreadPoolExecutorFactoryBean を検討してください。
導入:
2.0
作成者:
Juergen Hoeller
関連事項:
TaskExecutor, ThreadPoolExecutor, ConcurrentTaskExecutor, 連載形式

フィールドのサマリー
- クラス org.springframework.scheduling.concurrent.ExecutorConfigurationSupport から継承されたフィールド
  logger
- インターフェース org.springframework.core.task.AsyncTaskExecutor から継承されたフィールド
  TIMEOUT_IMMEDIATE, TIMEOUT_INDEFINITE

コンストラクターの概要
コンストラクター
コンストラクターと説明
ThreadPoolTaskExecutor()

コンストラクター
コンストラクターと説明
`ThreadPoolTaskExecutor()`

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected void`	`cancelRemainingTask(java.lang.Runnable task)` `ExecutorService.shutdownNow()` から返された、実行を決して賞賛しなかった残りのタスクをキャンセルします。
`protected java.util.concurrent.BlockingQueue<java.lang.Runnable>`	`createQueue(int queueCapacity)` BlockingQueue を作成して、ThreadPoolExecutor に使用します。
`void`	`execute(java.lang.Runnable task)` 指定された `task` を実行します。
`void`	`execute(java.lang.Runnable task, long startTimeout)` 指定された `task` を実行します。
`int`	`getActiveCount()` 現在アクティブなスレッドの数を返します。
`int`	`getCorePoolSize()` ThreadPoolExecutor のコアプールサイズを返します。
`int`	`getKeepAliveSeconds()` ThreadPoolExecutor のキープアライブ秒数を返します。
`int`	`getMaxPoolSize()` ThreadPoolExecutor の最大プールサイズを返します。
`int`	`getPoolSize()` 現在のプールサイズを返します。
`java.util.concurrent.ThreadPoolExecutor`	`getThreadPoolExecutor()` ネイティブアクセスの基になる ThreadPoolExecutor を返します。
`protected java.util.concurrent.ExecutorService`	`initializeExecutor(java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)` メモ: このメソッドは、`ExecutorService` をその基本クラスに公開しますが、実際の `ThreadPoolExecutor` ハンドルを内部に格納します。
`boolean`	`prefersShortLivedTasks()` このタスクエグゼキュータは、短期間のワークユニットを優先します。
`void`	`setAllowCoreThreadTimeOut(boolean allowCoreThreadTimeOut)` コアスレッドのタイムアウトを許可するかどうかを指定します。
`void`	`setCorePoolSize(int corePoolSize)` ThreadPoolExecutor のコアプールサイズを設定します。
`void`	`setKeepAliveSeconds(int keepAliveSeconds)` ThreadPoolExecutor のキープアライブ秒数を設定します。
`void`	`setMaxPoolSize(int maxPoolSize)` ThreadPoolExecutor の最大プールサイズを設定します。
`void`	`setQueueCapacity(int queueCapacity)` ThreadPoolExecutor の BlockingQueue の容量を設定します。
`void`	`setTaskDecorator(TaskDecorator taskDecorator)` 実行される `Runnable` に適用されるカスタム `TaskDecorator` を指定します。
`<T> java.util.concurrent.Future<T>`	`submit(java.util.concurrent.Callable<T> task)` Callable タスクを送信して実行し、そのタスクを表す Future を受け取ります。
`java.util.concurrent.Future<?>`	`submit(java.lang.Runnable task)` 実行可能な Runnable タスクを送信し、そのタスクを表す Future を受け取ります。
`<T> ListenableFuture<T>`	`submitListenable(java.util.concurrent.Callable<T> task)` `Callable` タスクを実行のために送信し、そのタスクを表す `ListenableFuture` を受け取ります。
`ListenableFuture<?>`	`submitListenable(java.lang.Runnable task)` `Runnable` タスクを実行のために送信し、そのタスクを表す `ListenableFuture` を受け取ります。

クラス org.springframework.scheduling.concurrent.ExecutorConfigurationSupport から継承されたメソッド
afterPropertiesSet, destroy, initialize, setAwaitTerminationSeconds, setBeanName, setRejectedExecutionHandler, setThreadFactory, setThreadNamePrefix, setWaitForTasksToCompleteOnShutdown, shutdown

クラス org.springframework.scheduling.concurrent.CustomizableThreadFactory から継承されたメソッド
newThread

クラス org.springframework.util.CustomizableThreadCreator から継承されたメソッド
createThread, getDefaultThreadNamePrefix, getThreadGroup, getThreadNamePrefix, getThreadPriority, isDaemon, nextThreadName, setDaemon, setThreadGroup, setThreadGroupName, setThreadPriority

クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- コンストラクターの詳細
  - ThreadPoolTaskExecutor
```
public 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 インスタンスにつながります。
    関連事項:
    LinkedBlockingQueue, SynchronousQueue
  - setAllowCoreThreadTimeOut
```
public void setAllowCoreThreadTimeOut(boolean allowCoreThreadTimeOut)
```
    コアスレッドのタイムアウトを許可するかどうかを指定します。これにより、ゼロ以外のキューと組み合わせても動的な拡大と縮小が可能になります（最大プールサイズはキューがいっぱいになると拡大するため）。
    デフォルトは「false」。
    関連事項:
    ThreadPoolExecutor.allowCoreThreadTimeOut(boolean)
  - setTaskDecorator
```
public void setTaskDecorator(TaskDecorator taskDecorator)
```
    実行される Runnable に適用されるカスタム TaskDecorator を指定します。
    このようなデコレータは、必ずしもユーザー提供の Runnable/Callable に適用されるのではなく、実際の実行コールバック（ユーザー提供のタスクのラッパーである可能性があります）に適用されることに注意してください。
    主な使用例は、タスクの呼び出しの周囲に実行コンテキストを設定するか、タスク実行の監視 / 統計を提供することです。
    導入:
    4.3
  - initializeExecutor
```
protected java.util.concurrent.ExecutorService initializeExecutor(java.util.concurrent.ThreadFactory threadFactory,
                                                                  java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)
```
    メモ: このメソッドは、ExecutorService をその基本クラスに公開しますが、実際の ThreadPoolExecutor ハンドルを内部に格納します。エグゼキュータを置き換えるためにこのメソッドをオーバーライドしないでください。ExecutorService ハンドルを装飾したり、カスタム状態を保存したりするためだけに使用してください。
    次で指定:
    クラス ExecutorConfigurationSupport の initializeExecutor
    パラメーター:
    threadFactory - 使用する ThreadFactory
    rejectedExecutionHandler - 使用する RejectedExecutionHandler
    戻り値:
    新しい ExecutorService インスタンス
    関連事項:
    ExecutorConfigurationSupport.afterPropertiesSet()
  - createQueue
```
protected java.util.concurrent.BlockingQueue<java.lang.Runnable> createQueue(int queueCapacity)
```
    BlockingQueue を作成して、ThreadPoolExecutor に使用します。
    正の容量値に対して LinkedBlockingQueue インスタンスが作成されます。SynchronousQueue その他。
    パラメーター:
    queueCapacity - 指定されたキュー容量
    戻り値:
    BlockingQueue インスタンス
    関連事項:
    LinkedBlockingQueue, SynchronousQueue
  - getThreadPoolExecutor
```
public java.util.concurrent.ThreadPoolExecutor getThreadPoolExecutor()
                                                              throws java.lang.IllegalStateException
```
    ネイティブアクセスの基になる ThreadPoolExecutor を返します。
    戻り値:
    基になる ThreadPoolExecutor (非 null)
    例外:
    java.lang.IllegalStateException - ThreadPoolTaskExecutor がまだ初期化されていない場合
  - getPoolSize
```
public int getPoolSize()
```
    現在のプールサイズを返します。
    関連事項:
    ThreadPoolExecutor.getPoolSize()
  - getActiveCount
```
public int getActiveCount()
```
    現在アクティブなスレッドの数を返します。
    関連事項:
    ThreadPoolExecutor.getActiveCount()
  - execute
```
public void execute(java.lang.Runnable task)
```
    インターフェースからコピーされた説明: TaskExecutor
    指定された task を実行します。
    実装が非同期実行戦略を使用している場合、呼び出しはすぐに戻るか、同期実行の場合はブロックする可能性があります。
    次で指定:
    インターフェース java.util.concurrent.Executor の execute
    次で指定:
    インターフェース TaskExecutor の execute
    パラメーター:
    task - 実行する Runnable (非 null)
  - execute
```
public void execute(java.lang.Runnable task,
                    long startTimeout)
```
    インターフェースからコピーされた説明: AsyncTaskExecutor
    指定された task を実行します。
    次で指定:
    インターフェース AsyncTaskExecutor の execute
    パラメーター:
    task - 実行する Runnable (非 null)
    startTimeout - タスクが開始される予定の期間（ミリ秒）。これはエグゼキューターへのヒントとして意図されており、即時タスクの優先処理を可能にします。一般的な値は AsyncTaskExecutor.TIMEOUT_IMMEDIATE または AsyncTaskExecutor.TIMEOUT_INDEFINITE（TaskExecutor.execute(Runnable) で使用されるデフォルト）です。
  - submit
```
public java.util.concurrent.Future<?> submit(java.lang.Runnable task)
```
    インターフェースからコピーされた説明: AsyncTaskExecutor
    実行可能な Runnable タスクを送信し、そのタスクを表す Future を受け取ります。Future は完了時に null の結果を返します。
    次で指定:
    インターフェース AsyncTaskExecutor の submit
    パラメーター:
    task - 実行する Runnable (非 null)
    戻り値:
    タスクの保留中の完了を表す Future
  - submit
```
public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task)
```
    インターフェースからコピーされた説明: AsyncTaskExecutor
    Callable タスクを送信して実行し、そのタスクを表す Future を受け取ります。Future は、完了時に Callable の結果を返します。
    次で指定:
    インターフェース AsyncTaskExecutor の submit
    パラメーター:
    task - 実行する Callable (非 null)
    戻り値:
    タスクの保留中の完了を表す Future
  - submitListenable
```
public ListenableFuture<?> submitListenable(java.lang.Runnable task)
```
    インターフェースからコピーされた説明: AsyncListenableTaskExecutor
    Runnable タスクを実行のために送信し、そのタスクを表す ListenableFuture を受け取ります。Future は完了時に null の結果を返します。
    次で指定:
    インターフェース AsyncListenableTaskExecutor の submitListenable
    パラメーター:
    task - 実行する Runnable (非 null)
    戻り値:
    保留中のタスクの完了を表す ListenableFuture
  - submitListenable
```
public <T> ListenableFuture<T> submitListenable(java.util.concurrent.Callable<T> task)
```
    インターフェースからコピーされた説明: AsyncListenableTaskExecutor
    Callable タスクを実行のために送信し、そのタスクを表す ListenableFuture を受け取ります。Future は、完了時に Callable の結果を返します。
    次で指定:
    インターフェース AsyncListenableTaskExecutor の submitListenable
    パラメーター:
    task - 実行する Callable (非 null)
    戻り値:
    保留中のタスクの完了を表す ListenableFuture
  - cancelRemainingTask
```
protected void cancelRemainingTask(java.lang.Runnable task)
```
    クラスからコピーされた説明: ExecutorConfigurationSupport
    ExecutorService.shutdownNow() から返された、実行を決して賞賛しなかった残りのタスクをキャンセルします。
    オーバーライド:
    クラス ExecutorConfigurationSupport の cancelRemainingTask
    パラメーター:
    task - キャンセルするタスク (通常は RunnableFuture)
    関連事項:
    ExecutorConfigurationSupport.shutdown(), Future.cancel(boolean)
  - prefersShortLivedTasks
```
public boolean prefersShortLivedTasks()
```
    このタスクエグゼキュータは、短期間のワークユニットを優先します。
    次で指定:
    インターフェース SchedulingTaskExecutor の prefersShortLivedTasks
    戻り値:
    true は、この TaskExecutor が短期タスクを好む場合

クラス ThreadPoolTaskExecutor

フィールドのサマリー

クラス org.springframework.scheduling.concurrent.ExecutorConfigurationSupport から継承されたフィールド

インターフェース org.springframework.core.task.AsyncTaskExecutor から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.scheduling.concurrent.ExecutorConfigurationSupport から継承されたメソッド

クラス org.springframework.scheduling.concurrent.CustomizableThreadFactory から継承されたメソッド

クラス org.springframework.util.CustomizableThreadCreator から継承されたメソッド

クラス java.lang.Object から継承されたメソッド

コンストラクターの詳細

ThreadPoolTaskExecutor

メソッドの詳細

setCorePoolSize

getCorePoolSize

setMaxPoolSize

getMaxPoolSize

setKeepAliveSeconds

getKeepAliveSeconds

setQueueCapacity

setAllowCoreThreadTimeOut

setTaskDecorator

initializeExecutor

createQueue

getThreadPoolExecutor

getPoolSize

getActiveCount

execute

execute

submit

submit

submitListenable

submitListenable

cancelRemainingTask

prefersShortLivedTasks