クラス SimpleAsyncTaskScheduler

メソッドの詳細

• setErrorHandler

  public void setErrorHandler(ErrorHandler errorHandler)

  ErrorHandler 戦略を提供します。

  導入:

  6.2

• setClock

  public void setClock(ClockSE clock)

  スケジューリングの目的で使用する監視を設定します。

  デフォルトのクロックは、デフォルトのタイムゾーンのシステムクロックです。

  関連事項:

  • Clock.systemDefaultZone()

• getClock

  public ClockSE getClock()

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

  スケジューリングの目的で使用する監視を返します。

  次で指定:

  インターフェース TaskScheduler の getClock 

  関連事項:

  • Clock.systemDefaultZone()

• setPhase

  public void setPhase(int phase)

  このエグゼキュータを一時停止および再開するためのライフサイクルフェーズを指定します。デフォルトは DEFAULT_PHASE です。

  関連事項:

  • SmartLifecycle.getPhase()

• getPhase

  public int getPhase()

  このエグゼキュータを一時停止および再開するためのライフサイクルフェーズを返します。

  次で指定:

  インターフェース Phased の getPhase 

  次で指定:

  インターフェース SmartLifecycle の getPhase 

  関連事項:

  • setPhase(int)

• setTargetTaskExecutor

  public void setTargetTaskExecutor(ExecutorSE targetTaskExecutor)

  スケジュールされたタスクの個別の実行を委譲するカスタムターゲット ExecutorSE を指定します。たとえば、このスケジューラは単一のスケジューラスレッドを使用し続ける一方で、スケジュールされたタスクを実行するために別のスレッドプールに設定できます。

  設定されていない場合、通常の SimpleAsyncTaskExecutor 配置がタスクごとに新しいスレッドで開始されます。

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext)

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

  このオブジェクトが実行される ApplicationContext を設定します。通常、この呼び出しはオブジェクトの初期化に使用されます。

  通常の Bean プロパティの設定後、ただし InitializingBean.afterPropertiesSet() またはカスタム init メソッドなどの init コールバックの前に呼び出されます。ResourceLoaderAware.setResourceLoader(org.springframework.core.io.ResourceLoader)、ApplicationEventPublisherAware.setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher) および MessageSourceAware の後に呼び出されます（該当する場合）。

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  パラメーター:

  applicationContext - このオブジェクトによって使用される ApplicationContext オブジェクト

  関連事項:

  • BeanInitializationException

• doExecute

  protected void doExecute(RunnableSE task)

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

  タスクを実際に実行するためのテンプレートメソッド。

  デフォルトの実装では、新しいスレッドを作成して開始します。

  オーバーライド:

  クラス SimpleAsyncTaskExecutor の doExecute 

  パラメーター:

  task - 実行する Runnable

  関連事項:

  • SimpleAsyncTaskExecutor.newThread(java.lang.Runnable)
  • Thread.start()

• execute

  public void execute(RunnableSE task)

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

  （スーパークラスの設定を介して）構成されている場合、同時実行スロットル内で、指定されたタスクを実行します。

  次で指定:

  インターフェース ExecutorSE の executeSE 

  次で指定:

  インターフェース TaskExecutor の execute 

  オーバーライド:

  クラス SimpleAsyncTaskExecutor の execute 

  パラメーター:

  task - 実行する Runnable (非 null)

  関連事項:

  • SimpleAsyncTaskExecutor.doExecute(Runnable)

• submit

  public FutureSE<?> submit(RunnableSE task)

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

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

  6.1 では、このメソッドには TaskExecutor.execute(Runnable) に委譲するデフォルトの実装が付属しています。

  次で指定:

  インターフェース AsyncTaskExecutor の submit 

  オーバーライド:

  クラス SimpleAsyncTaskExecutor の submit 

  パラメーター:

  task - 実行する Runnable (非 null)

  戻り値:

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

• submit

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

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

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

  6.1 では、このメソッドには TaskExecutor.execute(Runnable) に委譲するデフォルトの実装が付属しています。

  次で指定:

  インターフェース AsyncTaskExecutor の submit 

  オーバーライド:

  クラス SimpleAsyncTaskExecutor の submit 

  パラメーター:

  task - 実行する Callable (非 null)

  戻り値:

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

• submitListenable

  public ListenableFuture<?> submitListenable(RunnableSE task)

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

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

  次で指定:

  インターフェース AsyncListenableTaskExecutor の submitListenable 

  オーバーライド:

  クラス SimpleAsyncTaskExecutor の submitListenable 

  パラメーター:

  task - 実行する Runnable (非 null)

  戻り値:

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

• submitListenable

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

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

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

  次で指定:

  インターフェース AsyncListenableTaskExecutor の submitListenable 

  オーバーライド:

  クラス SimpleAsyncTaskExecutor の submitListenable 

  パラメーター:

  task - 実行する Callable (非 null)

  戻り値:

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

• schedule

  @Nullable public ScheduledFutureSE<?> schedule(RunnableSE task, Trigger trigger)

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

  指定された RunnableSE をスケジュールし、トリガーが次の実行時間を示すたびに呼び出します。

  スケジューラがシャットダウンするか、返された ScheduledFutureSE がキャンセルされると、実行は終了します。

  次で指定:

  インターフェース TaskScheduler の schedule 

  パラメーター:

  task - トリガーが起動するたびに実行する Runnable

  trigger - Trigger インターフェースの実装、たとえば cron 式をラップする CronTrigger オブジェクト

  戻り値:

  タスクの実行保留を表す ScheduledFutureSE、または指定されたトリガーオブジェクトが決して起動しない場合は null (つまり、Trigger.nextExecution(org.springframework.scheduling.TriggerContext) から null を返します)

  関連事項:

  • CronTrigger

• schedule

  public ScheduledFutureSE<?> schedule(RunnableSE task, InstantSE startTime)

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

  指定された RunnableSE をスケジュールし、指定された実行時間に呼び出します。

  スケジューラがシャットダウンするか、返された ScheduledFutureSE がキャンセルされると、実行は終了します。

  次で指定:

  インターフェース TaskScheduler の schedule 

  パラメーター:

  task - トリガーが起動するたびに実行する Runnable

  startTime - タスクの望ましい実行時間 (これが過去の場合、タスクはすぐに、つまりできるだけ早く実行されます)

  戻り値:

  タスクの保留中の実行を表す ScheduledFutureSE

• scheduleAtFixedRate

  public ScheduledFutureSE<?> scheduleAtFixedRate(RunnableSE task, InstantSE startTime, DurationSE period)

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

  指定された RunnableSE をスケジュールし、指定された実行時間に呼び出し、その後、指定された期間で呼び出します。

  スケジューラがシャットダウンするか、返された ScheduledFutureSE がキャンセルされると、実行は終了します。

  次で指定:

  インターフェース TaskScheduler の scheduleAtFixedRate 

  パラメーター:

  task - トリガーが起動するたびに実行する Runnable

  startTime - タスクに必要な最初の実行時間 (これが過去の場合、タスクはすぐに、つまりできるだけ早く実行されます)

  period - タスクの連続した実行の間隔

  戻り値:

  タスクの保留中の実行を表す ScheduledFutureSE

• scheduleAtFixedRate

  public ScheduledFutureSE<?> scheduleAtFixedRate(RunnableSE task, DurationSE period)

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

  指定された RunnableSE をスケジュールします。できるだけ早く開始し、指定された期間で呼び出します。

  スケジューラがシャットダウンするか、返された ScheduledFutureSE がキャンセルされると、実行は終了します。

  次で指定:

  インターフェース TaskScheduler の scheduleAtFixedRate 

  パラメーター:

  task - トリガーが起動するたびに実行する Runnable

  period - タスクの連続した実行の間隔

  戻り値:

  タスクの保留中の実行を表す ScheduledFutureSE

• scheduleWithFixedDelay

  public ScheduledFutureSE<?> scheduleWithFixedDelay(RunnableSE task, InstantSE startTime, DurationSE delay)

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

  指定された RunnableSE をスケジュールし、指定された実行時間に呼び出し、その後、1 つの実行が完了してから次の実行が開始されるまでの間に指定された遅延で呼び出します。

  スケジューラがシャットダウンするか、返された ScheduledFutureSE がキャンセルされると、実行は終了します。

  次で指定:

  インターフェース TaskScheduler の scheduleWithFixedDelay 

  パラメーター:

  task - トリガーが起動するたびに実行する Runnable

  startTime - タスクに必要な最初の実行時間 (これが過去の場合、タスクはすぐに、つまりできるだけ早く実行されます)

  delay - ある実行の補完から次の実行の開始までの遅延

  戻り値:

  タスクの保留中の実行を表す ScheduledFutureSE

• scheduleWithFixedDelay

  public ScheduledFutureSE<?> scheduleWithFixedDelay(RunnableSE task, DurationSE delay)

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

  指定された RunnableSE をスケジュールします。できるだけ早く開始し、1 つの実行が完了してから次の実行が開始されるまでの間に指定された遅延で呼び出します。

  スケジューラがシャットダウンするか、返された ScheduledFutureSE がキャンセルされると、実行は終了します。

  次で指定:

  インターフェース TaskScheduler の scheduleWithFixedDelay 

  パラメーター:

  task - トリガーが起動するたびに実行する Runnable

  delay - ある実行の補完から次の実行の開始までの遅延

  戻り値:

  タスクの保留中の実行を表す ScheduledFutureSE

• start

  public void start()

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

  このコンポーネントを起動します。

  コンポーネントがすでに実行されている場合は、例外をスローしないでください。

  コンテナーの場合、これにより、自動起動しないコンポーネントも含め、適用されるすべてのコンポーネントにハードスタートシグナルが伝播されます。

  次で指定:

  インターフェース Lifecycle の start 

  関連事項:

  • SmartLifecycle.isAutoStartup()

• stop

  public void stop()

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

  このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。非同期停止動作が必要な場合は、SmartLifecycle とその stop(Runnable) バリアントの実装を検討してください。

  この停止通知は破棄前に送信されるとは限らないことに注意してください。通常のシャットダウンでは、一般的な破棄コールバックが伝播される前に、Lifecycle Bean は最初に停止通知を受信します。ただし、コンテキストの存続期間中のホットリフレッシュまたは中断されたリフレッシュ試行では、特定の Bean の destroy メソッドが、停止シグナルを事前に考慮することなく呼び出されます。

  コンポーネントが実行されていない（まだ開始されていない）場合は、例外をスローしないでください。

  コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。

  次で指定:

  インターフェース Lifecycle の stop 

  関連事項:

  • SmartLifecycle.stop(Runnable)
  • DisposableBean.destroy()

• stop

  public void stop(RunnableSE callback)

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

  Lifecycle コンポーネントが現在実行中の場合、停止する必要があることを示します。

  提供されたコールバックは、LifecycleProcessor によって使用され、共通のシャットダウン順序値を持つすべてのコンポーネントの順序付けられた、潜在的に同時のシャットダウンをサポートします。コールバック は、SmartLifecycle コンポーネントが実際に停止した後に実行する必要があります。

  LifecycleProcessor は、stop メソッドのこのバリアントのみを呼び出します。つまり、SmartLifecycle 実装では、このメソッドの実装内に明示的に委譲されない限り、Lifecycle.stop() は呼び出されません。

  デフォルトの実装は Lifecycle.stop() に委譲し、呼び出しスレッドで指定されたコールバックをすぐにトリガーします。2 つの間に同期がないことに注意してください。カスタム実装では、少なくとも共通のライフサイクルモニター（存在する場合）内に同じ手順を入れたい場合があります。

  次で指定:

  インターフェース SmartLifecycle の stop 

  関連事項:

  • Lifecycle.stop()
  • SmartLifecycle.getPhase()

• isRunning

  public boolean isRunning()

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

  このコンポーネントが現在実行されているかどうかを確認します。

  コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、true を返します。

  次で指定:

  インターフェース Lifecycle の isRunning 

  戻り値:

  コンポーネントが現在実行中かどうか

• onApplicationEvent

  public void onApplicationEvent(ContextClosedEvent event)

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

  アプリケーションイベントを処理します。

  次で指定:

  インターフェース ApplicationListener<ContextClosedEvent> の onApplicationEvent 

  パラメーター:

  event - 応答するイベント

• close

  public void close()

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

  この close メソッドは、具体的な task termination timeout が設定されている場合、アクティブなスレッドの終了を追跡します。それ以外の場合は、この executor を閉じる必要はありません。

  次で指定:

  インターフェース AutoCloseableSE の close 

  オーバーライド:

  クラス SimpleAsyncTaskExecutor の close