Package com.github.akurilov.concurrent.coroutines

Class CoroutineBase

java.lang.Object

com.github.akurilov.concurrent.AsyncRunnableBase

com.github.akurilov.concurrent.coroutines.CoroutineBase

All Implemented Interfaces:

AsyncRunnable, Coroutine, java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

ExclusiveCoroutineBase, HelloWorldCoroutine, RoundRobinOutputCoroutine

public abstract class CoroutineBase
extends AsyncRunnableBase
implements Coroutine

The base class for all coroutines.

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.akurilov.concurrent.AsyncRunnable

AsyncRunnable.State

Field Summary

Fields inherited from class com.github.akurilov.concurrent.AsyncRunnableBase

state

Fields inherited from interface com.github.akurilov.concurrent.coroutines.Coroutine

TIMEOUT_NANOS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CoroutineBase(CoroutinesExecutor executor)

Method Summary

Modifier and Type	Method	Description
protected void	doStart()
protected void	doStop()
void	invoke()	Decorates the invocation method with timing.
protected abstract void	invokeTimed(long startTimeNanos)	The method implementation should use the start time to check its own duration in order to not to exceed the invocation time limit (100 ms)

Methods inherited from interface com.github.akurilov.concurrent.AsyncRunnable

await, await, isClosed, isFinished, isInitial, isShutdown, isStarted, isStopped, shutdown, start, state, stop

Methods inherited from class com.github.akurilov.concurrent.AsyncRunnableBase

await, await, close, doClose, doShutdown, isClosed, isFinished, isInitial, isShutdown, isStarted, isStopped, shutdown, start, state, stop

Methods inherited from interface java.io.Closeable

close

Methods inherited from class java.lang.Object

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

Constructor Detail

CoroutineBase

protected CoroutineBase(CoroutinesExecutor executor)

Method Detail

doStart

protected void doStart()

Overrides:

doStart in class AsyncRunnableBase

invoke

public final void invoke()

Decorates the invocation method with timing.

Specified by:

invoke in interface Coroutine

invokeTimed

protected abstract void invokeTimed(long startTimeNanos)

The method implementation should use the start time to check its own duration in order to not to exceed the invocation time limit (100 ms)

Parameters:

startTimeNanos - the time when the invocation started

doStop

protected void doStop()

Overrides:

doStop in class AsyncRunnableBase