Package io.fluxcapacitor.common.tracking

Interface TaskScheduler

All Known Implementing Classes:

InMemoryTaskScheduler

public interface TaskScheduler

Method Summary

Modifier and Type	Method	Description
Clock	clock()
void	executeExpiredTasks()
default <R> CompletableFuture<R>	orTimeout(CompletableFuture<R> future, Duration timeout)
Registration	schedule(long deadline, ThrowingRunnable task)
default Registration	schedule(Duration duration, ThrowingRunnable task)
default Registration	schedule(Instant deadline, ThrowingRunnable task)
void	shutdown()
default void	submit(ThrowingRunnable task)

Method Details

submit

default void submit(ThrowingRunnable task)

schedule

default Registration schedule(Duration duration,
 ThrowingRunnable task)

schedule

default Registration schedule(Instant deadline,
 ThrowingRunnable task)

schedule

Registration schedule(long deadline,
 ThrowingRunnable task)

orTimeout

default <R> CompletableFuture<R> orTimeout(CompletableFuture<R> future,
 Duration timeout)

clock

Clock clock()

executeExpiredTasks

void executeExpiredTasks()

shutdown

void shutdown()