ThreadPoolTaskScheduler (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.ThreadPoolTaskScheduler

実装されているすべてのインターフェース:
java.io.Serializable, java.util.concurrent.Executor, java.util.concurrent.ThreadFactory, Aware, BeanNameAware, DisposableBean, InitializingBean, AsyncListenableTaskExecutor, AsyncTaskExecutor, TaskExecutor, SchedulingTaskExecutor, TaskScheduler
```
public class ThreadPoolTaskScheduler
extends ExecutorConfigurationSupport
implements AsyncListenableTaskExecutor, SchedulingTaskExecutor, TaskScheduler
```
Spring の TaskScheduler インターフェースの実装で、ネイティブ ScheduledThreadPoolExecutor をラップします。
導入:
3.0
作成者:
Juergen Hoeller, Mark Fisher
関連事項:
setPoolSize(int), setRemoveOnCancelPolicy(boolean), ExecutorConfigurationSupport.setThreadFactory(java.util.concurrent.ThreadFactory), setErrorHandler(org.springframework.util.ErrorHandler), 連載形式

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

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

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

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected void`	`cancelRemainingTask(java.lang.Runnable task)` `ExecutorService.shutdownNow()` から返された、実行を決して賞賛しなかった残りのタスクをキャンセルします。
`protected java.util.concurrent.ScheduledExecutorService`	`createExecutor(int poolSize, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)` 新しい `ScheduledExecutorService` インスタンスを作成します。
`void`	`execute(java.lang.Runnable task)` 指定された `task` を実行します。
`void`	`execute(java.lang.Runnable task, long startTimeout)` 指定された `task` を実行します。
`int`	`getActiveCount()` 現在アクティブなスレッドの数を返します。
`int`	`getPoolSize()` 現在のプールサイズを返します。
`java.util.concurrent.ScheduledExecutorService`	`getScheduledExecutor()` ネイティブアクセスの基になる ScheduledExecutorService を返します。
`java.util.concurrent.ScheduledThreadPoolExecutor`	`getScheduledThreadPoolExecutor()` 可能であれば、基礎となる ScheduledThreadPoolExecutor を返します。
`protected java.util.concurrent.ExecutorService`	`initializeExecutor(java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)` ターゲット `ExecutorService` インスタンスを作成します。
`boolean`	`isRemoveOnCancelPolicy()` キャンセル時に削除モードの現在の設定を返します。
`boolean`	`prefersShortLivedTasks()` この `TaskExecutor` は、長命のタスクよりも短命のタスクを好みますか？
`java.util.concurrent.ScheduledFuture<?>`	`schedule(java.lang.Runnable task, java.util.Date startTime)` 指定された `Runnable` をスケジュールし、指定された実行時間に起動します。
`java.util.concurrent.ScheduledFuture<?>`	`schedule(java.lang.Runnable task, Trigger trigger)` 指定された `Runnable` をスケジュールし、トリガーが次の実行時間を示したときに起動します。
`java.util.concurrent.ScheduledFuture<?>`	`scheduleAtFixedRate(java.lang.Runnable task, java.util.Date startTime, long period)` 指定された `Runnable` をスケジュールして、指定された実行時間に起動し、その後、指定された期間で起動します。
`java.util.concurrent.ScheduledFuture<?>`	`scheduleAtFixedRate(java.lang.Runnable task, long period)` 指定された `Runnable` をスケジュールします。できるだけ早く開始し、指定された期間で起動します。
`java.util.concurrent.ScheduledFuture<?>`	`scheduleWithFixedDelay(java.lang.Runnable task, java.util.Date startTime, long delay)` 指定された `Runnable` をスケジュールして、指定された実行時間に起動し、その後、ある実行の補完から次の実行の開始までの間に指定された遅延を設定します。
`java.util.concurrent.ScheduledFuture<?>`	`scheduleWithFixedDelay(java.lang.Runnable task, long delay)` 指定された `Runnable` をスケジュールして、できるだけ早く開始し、1 つの実行の補完から次の実行の開始までの間に指定された遅延を指定して呼び出します。
`void`	`setErrorHandler(ErrorHandler errorHandler)` カスタム `ErrorHandler` 戦略を設定します。
`void`	`setPoolSize(int poolSize)` ScheduledExecutorService のプールサイズを設定します。
`void`	`setRemoveOnCancelPolicy(boolean removeOnCancelPolicy)` `ScheduledThreadPoolExecutor` （JDK 7+）で削除時の取り消しモードを設定します。
`<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

インターフェース org.springframework.scheduling.TaskScheduler から継承されたメソッド
schedule, scheduleAtFixedRate, scheduleAtFixedRate, scheduleWithFixedDelay, scheduleWithFixedDelay

- コンストラクターの詳細
  - ThreadPoolTaskScheduler
```
public ThreadPoolTaskScheduler()
```
- メソッドの詳細
  - setPoolSize
```
public void setPoolSize(int poolSize)
```
    ScheduledExecutorService のプールサイズを設定します。デフォルトは 1 です。
    この設定は、JMX などを介して実行時に変更できます。
  - setRemoveOnCancelPolicy
```
public void setRemoveOnCancelPolicy(boolean removeOnCancelPolicy)
```
    ScheduledThreadPoolExecutor （JDK 7+）で削除時の取り消しモードを設定します。
    デフォルトは false です。true に設定されている場合、ターゲットエグゼキューターはキャンセル時に削除モードに切り替えられます（可能な場合は、ソフトフォールバックが使用されます）。
    この設定は、JMX などを介して実行時に変更できます。
  - setErrorHandler
```
public void setErrorHandler(ErrorHandler errorHandler)
```
    カスタム ErrorHandler 戦略を設定します。
  - initializeExecutor
```
protected java.util.concurrent.ExecutorService initializeExecutor(java.util.concurrent.ThreadFactory threadFactory,
                                                                  java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)
```
    クラスからコピーされた説明: ExecutorConfigurationSupport
    ターゲット ExecutorService インスタンスを作成します。afterPropertiesSet によって呼び出されます。
    次で指定:
    クラス ExecutorConfigurationSupport の initializeExecutor
    パラメーター:
    threadFactory - 使用する ThreadFactory
    rejectedExecutionHandler - 使用する RejectedExecutionHandler
    戻り値:
    新しい ExecutorService インスタンス
    関連事項:
    ExecutorConfigurationSupport.afterPropertiesSet()
  - createExecutor
```
protected java.util.concurrent.ScheduledExecutorService createExecutor(int poolSize,
                                                                       java.util.concurrent.ThreadFactory threadFactory,
                                                                       java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)
```
    新しい ScheduledExecutorService インスタンスを作成します。
    デフォルトの実装は ScheduledThreadPoolExecutor を作成します。カスタム ScheduledExecutorService インスタンスを提供するためにサブクラスでオーバーライドできます。
    パラメーター:
    poolSize - 指定されたプールサイズ
    threadFactory - 使用する ThreadFactory
    rejectedExecutionHandler - 使用する RejectedExecutionHandler
    戻り値:
    新しい ScheduledExecutorService インスタンス
    関連事項:
    ExecutorConfigurationSupport.afterPropertiesSet(), ScheduledThreadPoolExecutor
  - getScheduledExecutor
```
public java.util.concurrent.ScheduledExecutorService getScheduledExecutor()
                                                                   throws java.lang.IllegalStateException
```
    ネイティブアクセスの基になる ScheduledExecutorService を返します。
    戻り値:
    基になる ScheduledExecutorService (非 null)
    例外:
    java.lang.IllegalStateException - ThreadPoolTaskScheduler がまだ初期化されていない場合
  - getScheduledThreadPoolExecutor
```
public java.util.concurrent.ScheduledThreadPoolExecutor getScheduledThreadPoolExecutor()
                                                                                throws java.lang.IllegalStateException
```
    可能であれば、基礎となる ScheduledThreadPoolExecutor を返します。
    戻り値:
    基になる ScheduledExecutorService (非 null)
    例外:
    java.lang.IllegalStateException - ThreadPoolTaskScheduler がまだ初期化されていない場合、または基礎となる ScheduledExecutorService が ScheduledThreadPoolExecutor でない場合
    関連事項:
    getScheduledExecutor()
  - getPoolSize
```
public int getPoolSize()
```
    現在のプールサイズを返します。
    基礎となる ScheduledThreadPoolExecutor が必要です。
    関連事項:
    getScheduledThreadPoolExecutor(), ThreadPoolExecutor.getPoolSize()
  - isRemoveOnCancelPolicy
```
public boolean isRemoveOnCancelPolicy()
```
    キャンセル時に削除モードの現在の設定を返します。
    基礎となる ScheduledThreadPoolExecutor が必要です。
  - getActiveCount
```
public int getActiveCount()
```
    現在アクティブなスレッドの数を返します。
    基礎となる ScheduledThreadPoolExecutor が必要です。
    関連事項:
    getScheduledThreadPoolExecutor(), 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
    この TaskExecutor は、長命のタスクよりも短命のタスクを好みますか？
    SchedulingTaskExecutor 実装は、サブミットされたタスクが単一のタスク実行内で可能な限り少ない作業を実行することを好むかどうかを示すことができます。例: 送信されたタスクは、繰り返しループを個々のサブタスクに分割し、後で実行可能なタスクを送信します（可能な場合）。
    これはヒントと見なされる必要があります。もちろん、TaskExecutor クライアントはこのフラグを自由に無視できるため、SchedulingTaskExecutor インターフェースは全体的に無視されます。ただし、スレッドプールは通常、より詳細なスケジューリングを実行できるように、短時間のタスクを優先することを示します。
    次で指定:
    インターフェース SchedulingTaskExecutor の prefersShortLivedTasks
    戻り値:
    true は、この TaskExecutor が短期タスクを好む場合
  - schedule
```
@Nullable
public java.util.concurrent.ScheduledFuture<?> schedule(java.lang.Runnable task,
                                                                  Trigger trigger)
```
    インターフェースからコピーされた説明: TaskScheduler
    指定された Runnable をスケジュールし、トリガーが次の実行時間を示したときに起動します。
    スケジューラーがシャットダウンするか、返された ScheduledFuture がキャンセルされると、実行が終了します。
    次で指定:
    インターフェース TaskScheduler の schedule
    パラメーター:
    task - トリガーが起動するたびに実行する Runnable
    trigger - Trigger インターフェースの実装。cron 式をラップする CronTrigger オブジェクト
    戻り値:
    タスクの保留中の完了を表す ScheduledFuture、または指定された Trigger オブジェクトが起動しない場合は null (つまり、Trigger.nextExecutionTime(org.springframework.scheduling.TriggerContext) から null を返します)
    関連事項:
    CronTrigger
  - schedule
```
public java.util.concurrent.ScheduledFuture<?> schedule(java.lang.Runnable task,
                                                        java.util.Date startTime)
```
    インターフェースからコピーされた説明: TaskScheduler
    指定された Runnable をスケジュールし、指定された実行時間に起動します。
    スケジューラーがシャットダウンするか、返された ScheduledFuture がキャンセルされると、実行が終了します。
    次で指定:
    インターフェース TaskScheduler の schedule
    パラメーター:
    task - トリガーが起動するたびに実行する Runnable
    startTime - タスクの望ましい実行時間 (これが過去の場合、タスクはすぐに、つまりできるだけ早く実行されます)
    戻り値:
    保留中のタスクの完了を表す ScheduledFuture
  - scheduleAtFixedRate
```
public java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable task,
                                                                   java.util.Date startTime,
                                                                   long period)
```
    インターフェースからコピーされた説明: TaskScheduler
    指定された Runnable をスケジュールして、指定された実行時間に起動し、その後、指定された期間で起動します。
    スケジューラーがシャットダウンするか、返された ScheduledFuture がキャンセルされると、実行が終了します。
    次で指定:
    インターフェース TaskScheduler の scheduleAtFixedRate
    パラメーター:
    task - トリガーが起動するたびに実行する Runnable
    startTime - タスクに必要な最初の実行時間 (これが過去の場合、タスクはすぐに、つまりできるだけ早く実行されます)
    period - タスクの連続した実行の間隔 (ミリ秒単位)
    戻り値:
    保留中のタスクの完了を表す ScheduledFuture
  - scheduleAtFixedRate
```
public java.util.concurrent.ScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable task,
                                                                   long period)
```
    インターフェースからコピーされた説明: TaskScheduler
    指定された Runnable をスケジュールします。できるだけ早く開始し、指定された期間で起動します。
    スケジューラーがシャットダウンするか、返された ScheduledFuture がキャンセルされると、実行が終了します。
    次で指定:
    インターフェース TaskScheduler の scheduleAtFixedRate
    パラメーター:
    task - トリガーが起動するたびに実行する Runnable
    period - タスクの連続した実行の間隔 (ミリ秒単位)
    戻り値:
    保留中のタスクの完了を表す ScheduledFuture
  - scheduleWithFixedDelay
```
public java.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable task,
                                                                      java.util.Date startTime,
                                                                      long delay)
```
    インターフェースからコピーされた説明: TaskScheduler
    指定された Runnable をスケジュールして、指定された実行時間に起動し、その後、ある実行の補完から次の実行の開始までの間に指定された遅延を設定します。
    スケジューラーがシャットダウンするか、返された ScheduledFuture がキャンセルされると、実行が終了します。
    次で指定:
    インターフェース TaskScheduler の scheduleWithFixedDelay
    パラメーター:
    task - トリガーが起動するたびに実行する Runnable
    startTime - タスクに必要な最初の実行時間 (これが過去の場合、タスクはすぐに、つまりできるだけ早く実行されます)
    delay - ある実行の補完から次の実行の開始までの遅延 (ミリ秒単位)
    戻り値:
    保留中のタスクの完了を表す ScheduledFuture
  - scheduleWithFixedDelay
```
public java.util.concurrent.ScheduledFuture<?> scheduleWithFixedDelay(java.lang.Runnable task,
                                                                      long delay)
```
    インターフェースからコピーされた説明: TaskScheduler
    指定された Runnable をスケジュールして、できるだけ早く開始し、1 つの実行の補完から次の実行の開始までの間に指定された遅延を指定して呼び出します。
    スケジューラーがシャットダウンするか、返された ScheduledFuture がキャンセルされると、実行が終了します。
    次で指定:
    インターフェース TaskScheduler の scheduleWithFixedDelay
    パラメーター:
    task - トリガーが起動するたびに実行する Runnable
    delay - ある実行の補完から次の実行の開始までの遅延 (ミリ秒単位)
    戻り値:
    保留中のタスクの完了を表す ScheduledFuture

クラス ThreadPoolTaskScheduler

フィールドのサマリー

クラス 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 から継承されたメソッド

インターフェース org.springframework.scheduling.TaskScheduler から継承されたメソッド

コンストラクターの詳細

ThreadPoolTaskScheduler

メソッドの詳細

setPoolSize

setRemoveOnCancelPolicy

setErrorHandler

initializeExecutor

createExecutor

getScheduledExecutor

getScheduledThreadPoolExecutor

getPoolSize

isRemoveOnCancelPolicy

getActiveCount

execute

execute

submit

submit

submitListenable

submitListenable

cancelRemainingTask

prefersShortLivedTasks

schedule

schedule

scheduleAtFixedRate

scheduleAtFixedRate

scheduleWithFixedDelay

scheduleWithFixedDelay