パッケージ org.springframework.data.redis.stream

インターフェース Task

すべてのスーパーインターフェース:
Cancelable、RunnableSE、SchedulingAwareRunnable
public interface Task extends SchedulingAwareRunnable, Cancelable
StreamMessageListenerContainer 内で実行される実際の Task。
導入:
2.2
作成者:
Mark Paluch

  • ネストされたクラスの概要

    ネストされたクラス
    修飾子と型
    インターフェース
    説明
    static enum
    Task.State
    実際の Task のライフサイクルフェーズを定義する Task.State。

  • 方法の概要

    修飾子と型
    メソッド
    説明
    boolean
    awaitStart(DurationSE timeout)
    この Task がアクティブになるまで待機する同期ブロッキングコール。
    Task.State
    getState()
    現在のライフサイクルフェーズを取得します。
    default boolean
    isActive()

    インターフェース org.springframework.data.redis.stream.Cancelable から継承されたメソッド

    cancel

    インターフェース java.lang.RunnableSE から継承されたメソッド

    run

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

    getQualifier, isLongLived

  • 方法の詳細

    • isActive

      default boolean isActive()
      戻り値:
      タスクが現在 running の場合は true。

    • getState

      Task.State getState()
      現在のライフサイクルフェーズを取得します。
      戻り値:
      決して null にはなりません。

    • awaitStart

      boolean awaitStart(DurationSE timeout) throws InterruptedExceptionSE
      この Task がアクティブになるまで待機する同期ブロッキングコール。再起動をサポートするために、cancelling の後に待機開始が再起動されます。
      パラメーター:
      timeout - null であってはなりません。
      戻り値:
      タスクが開始された場合は true。タスクが開始される前に待機時間が経過した場合は false。
      例外:
      InterruptedExceptionSE - 待機中に現在のスレッドが中断された場合。