Package org.apache.cassandra.concurrent

Interface SequentialExecutorPlus.AtLeastOnceTrigger

All Known Implementing Classes:
SingleThreadExecutorPlus.AtLeastOnce
Enclosing interface:
SequentialExecutorPlus
public static interface SequentialExecutorPlus.AtLeastOnceTrigger

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    runAfter(Runnable run)
    Run the provided task after all queued and executing jobs have completed
    void
    sync()
    Wait until all queued and executing jobs have completed
    boolean
    trigger()
    Ensure the job is run at least once in its entirety after this method is invoked (including any already queued)

  • Method Details

    • trigger

      boolean trigger()
      Ensure the job is run at least once in its entirety after this method is invoked (including any already queued)

    • runAfter

      void runAfter(Runnable run)
      Run the provided task after all queued and executing jobs have completed

    • sync

      void sync()
      Wait until all queued and executing jobs have completed