Class DefaultTickLoop

java.lang.Object

eu.cloudnetservice.node.impl.tick.DefaultTickLoop

All Implemented Interfaces:

eu.cloudnetservice.node.tick.Scheduler, eu.cloudnetservice.node.tick.TickLoop

@Singleton
@Provides({eu.cloudnetservice.node.tick.TickLoop.class,eu.cloudnetservice.node.tick.Scheduler.class})
public final class DefaultTickLoop
extends Object
implements eu.cloudnetservice.node.tick.TickLoop, eu.cloudnetservice.node.tick.Scheduler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	DefaultTickLoop.ScheduledTask<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicLong	currentTick
private final eu.cloudnetservice.driver.event.EventManager	eventManager
private static final org.slf4j.Logger	LOGGER
static final int	MILLIS_BETWEEN_TICKS
private final eu.cloudnetservice.node.cluster.NodeServerProvider	nodeServerProvider
private final Queue<DefaultTickLoop.ScheduledTask<?>>	processQueue
(package private) static final AtomicBoolean	RUNNING
private final InternalCloudServiceManager	serviceManager
private final eu.cloudnetservice.node.event.instance.CloudNetTickServiceStartEvent	serviceTickStartEvent
private final jakarta.inject.Provider<DefaultShutdownHandler>	shutdownHandlerProvider
private final eu.cloudnetservice.driver.provider.ServiceTaskProvider	taskProvider
private final eu.cloudnetservice.node.event.instance.CloudNetTickEvent	tickEvent
private final AtomicInteger	tickPauseRequests

Fields inherited from interface eu.cloudnetservice.node.tick.TickLoop

TPS

Constructor Summary

Constructors

Constructor	Description
DefaultTickLoop(@NonNull eu.cloudnetservice.driver.event.EventManager eventManager, @NonNull eu.cloudnetservice.driver.provider.ServiceTaskProvider taskProvider, @NonNull InternalCloudServiceManager serviceManager, @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider, @NonNull jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider)

Method Summary

Modifier and Type	Method	Description
long	currentTick()
void	pause()
void	resume()
@NonNull CompletableFuture<Void>	runDelayedTask(@NonNull Runnable runnable, @NonNull Duration delay)
<T> @NonNull CompletableFuture<T>	runDelayedTask(@NonNull Callable<T> callable, @NonNull Duration delay)
boolean	running()
@NonNull CompletableFuture<Void>	runTask(@NonNull Runnable runnable)
<T> @NonNull CompletableFuture<T>	runTask(@NonNull Callable<T> callable)
@NonNull eu.cloudnetservice.node.tick.Scheduler	scheduler()
<T> @NonNull CompletableFuture<T>	scheduleTask(@NonNull Callable<T> callable, @NonNull Duration delay)
<T> @NonNull CompletableFuture<T>	scheduleTask(@NonNull Callable<T> callable, @NonNull Duration delay, int maxExecutions)
void	start()
private void	startService()

Methods inherited from class Object

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

Field Details

MILLIS_BETWEEN_TICKS

public static final int MILLIS_BETWEEN_TICKS

See Also:

• Constant Field Values

RUNNING

static final AtomicBoolean RUNNING

LOGGER

private static final org.slf4j.Logger LOGGER

eventManager

private final eu.cloudnetservice.driver.event.EventManager eventManager

taskProvider

private final eu.cloudnetservice.driver.provider.ServiceTaskProvider taskProvider

serviceManager

private final InternalCloudServiceManager serviceManager

nodeServerProvider

private final eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider

shutdownHandlerProvider

private final jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider

tickPauseRequests

private final AtomicInteger tickPauseRequests

tickEvent

private final eu.cloudnetservice.node.event.instance.CloudNetTickEvent tickEvent

serviceTickStartEvent

private final eu.cloudnetservice.node.event.instance.CloudNetTickServiceStartEvent serviceTickStartEvent

currentTick

private final AtomicLong currentTick

processQueue

private final Queue<DefaultTickLoop.ScheduledTask<?>> processQueue

Constructor Details

DefaultTickLoop

@Inject
public DefaultTickLoop(@NonNull
 @NonNull eu.cloudnetservice.driver.event.EventManager eventManager,
 @NonNull
 @NonNull eu.cloudnetservice.driver.provider.ServiceTaskProvider taskProvider,
 @NonNull
 @NonNull InternalCloudServiceManager serviceManager,
 @NonNull
 @NonNull eu.cloudnetservice.node.cluster.NodeServerProvider nodeServerProvider,
 @NonNull
 @NonNull jakarta.inject.Provider<DefaultShutdownHandler> shutdownHandlerProvider)

Method Details

runTask

@NonNull
public @NonNull CompletableFuture<Void> runTask(@NonNull
 @NonNull Runnable runnable)

Specified by:

runTask in interface eu.cloudnetservice.node.tick.Scheduler

runTask

@NonNull
public <T> @NonNull CompletableFuture<T> runTask(@NonNull
 @NonNull Callable<T> callable)

Specified by:

runTask in interface eu.cloudnetservice.node.tick.Scheduler

runDelayedTask

@NonNull
public @NonNull CompletableFuture<Void> runDelayedTask(@NonNull
 @NonNull Runnable runnable,
 @NonNull
 @NonNull Duration delay)

Specified by:

runDelayedTask in interface eu.cloudnetservice.node.tick.Scheduler

runDelayedTask

@NonNull
public <T> @NonNull CompletableFuture<T> runDelayedTask(@NonNull
 @NonNull Callable<T> callable,
 @NonNull
 @NonNull Duration delay)

Specified by:

runDelayedTask in interface eu.cloudnetservice.node.tick.Scheduler

scheduleTask

@NonNull
public <T> @NonNull CompletableFuture<T> scheduleTask(@NonNull
 @NonNull Callable<T> callable,
 @NonNull
 @NonNull Duration delay)

Specified by:

scheduleTask in interface eu.cloudnetservice.node.tick.Scheduler

scheduleTask

@NonNull
public <T> @NonNull CompletableFuture<T> scheduleTask(@NonNull
 @NonNull Callable<T> callable,
 @NonNull
 @NonNull Duration delay,
 int maxExecutions)

Specified by:

scheduleTask in interface eu.cloudnetservice.node.tick.Scheduler

scheduler

@NonNull
public @NonNull eu.cloudnetservice.node.tick.Scheduler scheduler()

Specified by:

scheduler in interface eu.cloudnetservice.node.tick.TickLoop

running

public boolean running()

Specified by:

running in interface eu.cloudnetservice.node.tick.TickLoop

pause

public void pause()

Specified by:

pause in interface eu.cloudnetservice.node.tick.TickLoop

resume

public void resume()

Specified by:

resume in interface eu.cloudnetservice.node.tick.TickLoop

currentTick

public long currentTick()

Specified by:

currentTick in interface eu.cloudnetservice.node.tick.TickLoop

start

public void start()

startService

private void startService()