hu.akarnokd.reactive4java.scheduler

Class CurrentThreadScheduler

java.lang.Object

hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler

All Implemented Interfaces:

Scheduler

public class CurrentThreadScheduler
extends java.lang.Object
implements Scheduler

Scheduler which runs tasks on the current thread. Timed or repeated tasks may block operations indefinitely.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.locks.Lock	lock The lock protecting the queue.
java.util.concurrent.atomic.AtomicLong	sequence The relative order for zero delay invocations.
protected java.util.PriorityQueue<hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler.DelayedRunnable>	tasks The priority queue for the tasks.
protected java.util.concurrent.atomic.AtomicInteger	wip The in progress value.

Constructor Summary

Constructors

Constructor and Description
CurrentThreadScheduler()

Method Summary

Modifier and Type	Method and Description
protected void	add(hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler.DelayedRunnable dr) Adds the given task.
protected hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler.DelayedRunnable	poll() Takes a task from the queue.
protected void	remove(hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler.DelayedRunnable dr) Removes the given task.
java.io.Closeable	schedule(java.lang.Runnable run) Schedule for ASAP execution.
java.io.Closeable	schedule(java.lang.Runnable run, long initialDelay, long betweenDelay, java.util.concurrent.TimeUnit unit) Schedule a repeated execution of the given task with the given initialDelay (in nanoseconds) and betweenDelay (in nanoseconds).
java.io.Closeable	schedule(java.lang.Runnable run, long delay, java.util.concurrent.TimeUnit unit) Schedule a single execution of the runnable task with the given delay of nanoseconds.

Methods inherited from class java.lang.Object

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

Field Detail

sequence

public final java.util.concurrent.atomic.AtomicLong sequence

The relative order for zero delay invocations.

wip

protected final java.util.concurrent.atomic.AtomicInteger wip

The in progress value.

lock

protected final java.util.concurrent.locks.Lock lock

The lock protecting the queue.

tasks

protected java.util.PriorityQueue<hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler.DelayedRunnable> tasks

The priority queue for the tasks.

Constructor Detail

CurrentThreadScheduler

public CurrentThreadScheduler()

Method Detail

add

protected void add(hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler.DelayedRunnable dr)

Adds the given task.

Parameters:

dr - the task

remove

protected void remove(hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler.DelayedRunnable dr)

Removes the given task.

Parameters:

dr - the task

poll

protected hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler.DelayedRunnable poll()

Takes a task from the queue.

Returns:

the task or null if no more tasks

schedule

@Nonnull
public java.io.Closeable schedule(@Nonnull
                                            java.lang.Runnable run)

Description copied from interface: Scheduler

Schedule for ASAP execution.

Specified by:

schedule in interface Scheduler

Parameters:

run - the runnable task

Returns:

the cancel handler

schedule

@Nonnull
public java.io.Closeable schedule(@Nonnull
                                            java.lang.Runnable run,
                                            long delay,
                                            @Nonnull
                                            java.util.concurrent.TimeUnit unit)

Description copied from interface: Scheduler

Schedule a single execution of the runnable task with the given delay of nanoseconds.

Specified by:

schedule in interface Scheduler

Parameters:

run - the task to run

delay - the initial delay,

unit - the delay time unit implementations might not have the capability to schedule in this resolution

Returns:

the cancel handler

schedule

@Nonnull
public java.io.Closeable schedule(@Nonnull
                                            java.lang.Runnable run,
                                            long initialDelay,
                                            long betweenDelay,
                                            @Nonnull
                                            java.util.concurrent.TimeUnit unit)

Description copied from interface: Scheduler

Schedule a repeated execution of the given task with the given initialDelay (in nanoseconds) and betweenDelay (in nanoseconds). The expected semantics from the scheduler is to run the task at a fixed rate (i.e., ExecutorService.scheduleAtFixedRate()). Note: Implementations might not have the capability to schedule nanosecond resolution.

Specified by:

schedule in interface Scheduler

Parameters:

run - the task to run

initialDelay - the initial delay before the first run

betweenDelay - the delay between task runs after the

unit - the delay time unit

Returns:

the cancel handler