Class TrampolineScheduler.TrampolineWorker

    • Field Detail

      • wip

        private final java.util.concurrent.atomic.AtomicInteger wip
      • counter

        final java.util.concurrent.atomic.AtomicInteger counter
      • disposed

        volatile boolean disposed
    • Constructor Detail

      • TrampolineWorker

        TrampolineWorker()
    • Method Detail

      • schedule

        @NonNull
        public @NonNull Disposable schedule​(@NonNull
                                            @NonNull java.lang.Runnable action,
                                            long delayTime,
                                            @NonNull
                                            @NonNull java.util.concurrent.TimeUnit unit)
        Description copied from class: Scheduler.Worker
        Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.

        Note to implementors: non-positive delayTime should be regarded as non-delayed schedule, i.e., as if the Scheduler.Worker.schedule(Runnable) was called.

        Specified by:
        schedule in class Scheduler.Worker
        Parameters:
        action - the Runnable to schedule
        delayTime - time to "wait" before executing the action; non-positive values indicate an non-delayed schedule
        unit - the time unit of delayTime
        Returns:
        a Disposable to be able to unsubscribe the action (cancel it if not executed)
      • enqueue

        Disposable enqueue​(java.lang.Runnable action,
                           long execTime)
      • dispose

        public void dispose()
        Description copied from interface: Disposable
        Dispose the resource, the operation should be idempotent.
      • isDisposed

        public boolean isDisposed()
        Description copied from interface: Disposable
        Returns true if this resource has been disposed.
        Returns:
        true if this resource has been disposed