reactor.core.scheduler

Interface Scheduler.Worker

All Known Subinterfaces:

TimedScheduler.TimedWorker

Enclosing interface:

Scheduler

public static interface Scheduler.Worker

A worker representing an asynchronous boundary that executes tasks in a FIFO order, guaranteed non-concurrently with respect to each other.

Method Summary

Modifier and Type	Method and Description
Cancellation	schedule(java.lang.Runnable task) Schedules the task on this worker.
void	shutdown() Instructs this worker to cancel all pending tasks, all running tasks in a best-effort manner, reject new tasks and release any resources associated with it.

Method Detail

schedule

Cancellation schedule(java.lang.Runnable task)

Schedules the task on this worker.

Parameters:

task - the task to schedule

Returns:

the Cancellation instance that let's one cancel this particular task. If the Scheduler has been shut down, the Scheduler.REJECTED Cancellation instance is returned.

shutdown

void shutdown()

Instructs this worker to cancel all pending tasks, all running tasks in a best-effort manner, reject new tasks and release any resources associated with it.