Package io.helidon.microprofile.faulttolerance

Class CommandScheduler

java.lang.Object

io.helidon.microprofile.faulttolerance.CommandScheduler

All Implemented Interfaces:

net.jodah.failsafe.util.concurrent.Scheduler

public class CommandScheduler
extends Object
implements net.jodah.failsafe.util.concurrent.Scheduler

Class CommandScheduler.

Field Summary

Fields inherited from interface net.jodah.failsafe.util.concurrent.Scheduler

DEFAULT

Method Summary

Modifier and Type	Method	Description
static CommandScheduler	create(int threadPoolSize)	If no command scheduler exists, creates one using default values.
ScheduledFuture<?>	schedule(Callable<?> callable, long delay, TimeUnit unit)	Schedules a task using an executor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static CommandScheduler create(int threadPoolSize)

If no command scheduler exists, creates one using default values. Disables daemon threads.

Parameters:

threadPoolSize - Size of thread pool for async commands.

Returns:

Existing scheduler or newly created one.

schedule

public ScheduledFuture<?> schedule(Callable<?> callable,
                                   long delay,
                                   TimeUnit unit)

Schedules a task using an executor.

Specified by:

schedule in interface net.jodah.failsafe.util.concurrent.Scheduler

Parameters:

callable - The callable.

delay - Delay before scheduling task.

unit - Unite of delay.

Returns:

Future to track task execution.