Package com.soulfiremc.server

Class SoulFireScheduler

java.lang.Object

com.soulfiremc.server.SoulFireScheduler

All Implemented Interfaces:

Executor

public final class SoulFireScheduler
extends Object
implements Executor

Lightweight scheduler for async tasks. Used for most of the async tasks in the server, bots and plugins.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SoulFireScheduler.RunnableIOException
static interface	SoulFireScheduler.RunnableWrapper

Constructor Summary

Constructors

Constructor	Description
SoulFireScheduler(SoulFireScheduler.RunnableWrapper runnableWrapper)

Method Summary

Modifier and Type	Method	Description
void	blockNewTasks()
void	drainQueue()
void	execute(@NonNull Runnable command)
CompletableFuture<?>	runAsync(Runnable command)
CompletableFuture<?>	runAsync(Runnable command, org.slf4j.event.Level errorLevel)
void	schedule(Runnable command)
void	schedule(Runnable command, long delay, TimeUnit unit)
void	scheduleAtFixedRate(Runnable command, long delay, long period, TimeUnit unit)
void	scheduleWithDynamicDelay(Runnable command, LongSupplier delay, TimeUnit unit)
void	scheduleWithFixedDelay(Runnable command, long delay, long period, TimeUnit unit)
void	shutdown()
<T> CompletableFuture<T>	supplyAsync(Supplier<T> command)
<T> CompletableFuture<T>	supplyAsync(Supplier<T> command, org.slf4j.event.Level errorLevel)

Methods inherited from class java.lang.Object

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

Constructor Details

SoulFireScheduler

public SoulFireScheduler(SoulFireScheduler.RunnableWrapper runnableWrapper)

Method Details

schedule

public void schedule(Runnable command)

schedule

public void schedule(Runnable command,
 long delay,
 TimeUnit unit)

scheduleAtFixedRate

public void scheduleAtFixedRate(Runnable command,
 long delay,
 long period,
 TimeUnit unit)

scheduleWithFixedDelay

public void scheduleWithFixedDelay(Runnable command,
 long delay,
 long period,
 TimeUnit unit)

scheduleWithDynamicDelay

public void scheduleWithDynamicDelay(Runnable command,
 LongSupplier delay,
 TimeUnit unit)

drainQueue

public void drainQueue()

shutdown

public void shutdown()

runAsync

public CompletableFuture<?> runAsync(Runnable command)

supplyAsync

public <T> CompletableFuture<T> supplyAsync(Supplier<T> command)

runAsync

public CompletableFuture<?> runAsync(Runnable command,
 org.slf4j.event.Level errorLevel)

supplyAsync

public <T> CompletableFuture<T> supplyAsync(Supplier<T> command,
 org.slf4j.event.Level errorLevel)

blockNewTasks

public void blockNewTasks()

execute

public void execute(@NonNull Runnable command)

Specified by:

execute in interface Executor