Class TaskSchedulingAction

java.lang.Object

eu.cloudnetservice.driver.impl.network.scheduler.TaskSchedulingAction

All Implemented Interfaces:

Runnable

final class TaskSchedulingAction
extends Object
implements Runnable

The task scheduler runnable that is responsible for scheduling incoming tasks into the target executor service. Due to the fact that the scheduling action could be blocking, this action should be scheduled in a separate thread.

Since:

4.0

Field Summary

Fields

Modifier and Type	Field	Description
private final ThreadPoolExecutor	targetExecutor
private final LinkedBlockingQueue<Runnable>	unscheduledTasks

Constructor Summary

Constructors

Constructor	Description
TaskSchedulingAction(@NonNull ThreadPoolExecutor targetExecutor, @NonNull LinkedBlockingQueue<Runnable> unscheduledTaskQueue)	Constructs a new task scheduling action.

Method Summary

Modifier and Type	Method	Description
void	run()	Schedules tasks that were added to the unscheduled tasks queue into the target executor.
void	scheduleTask(@NonNull Runnable task)	Schedules the given task for execution.

Methods inherited from class Object

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

Field Details

targetExecutor

private final ThreadPoolExecutor targetExecutor

unscheduledTasks

private final LinkedBlockingQueue<Runnable> unscheduledTasks

Constructor Details

TaskSchedulingAction

public TaskSchedulingAction(@NonNull
 @NonNull ThreadPoolExecutor targetExecutor,
 @NonNull
 @NonNull LinkedBlockingQueue<Runnable> unscheduledTaskQueue)

Constructs a new task scheduling action.

Parameters:

targetExecutor - the executor to execute unscheduled tasks.

unscheduledTaskQueue - the queue for unscheduled tasks.

Throws:

NullPointerException - if the given target executor or unscheduled task queue is null.

Method Details

run

public void run()

Schedules tasks that were added to the unscheduled tasks queue into the target executor. This operation blocks until a task is available in the tasks queue.

Specified by:

run in interface Runnable

scheduleTask

public void scheduleTask(@NonNull
 @NonNull Runnable task)

Schedules the given task for execution.

Parameters:

task - the task to execute.

Throws:

NullPointerException - if the given task is null.