com.github.akurilov.concurrent.coroutines

Class ExclusiveCoroutineBase

java.lang.Object

com.github.akurilov.concurrent.AsyncRunnableBase

com.github.akurilov.concurrent.coroutines.CoroutineBase

com.github.akurilov.concurrent.coroutines.ExclusiveCoroutineBase

All Implemented Interfaces:

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

Direct Known Subclasses:

HelloWorldExclusiveCoroutine, TransferCoroutine

public abstract class ExclusiveCoroutineBase
extends CoroutineBase

The base class for a coroutine implementation which may not be executed in parallel.

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 and Description
protected	ExclusiveCoroutineBase(CoroutinesExecutor executor)
protected	ExclusiveCoroutineBase(CoroutinesExecutor executor, java.util.concurrent.locks.Lock invocationLock)

Method Summary

Modifier and Type	Method and Description
protected 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)
protected abstract void	invokeTimedExclusively(long startTimeNanos) The method is guaranteed to be executing only in a single thread.

Methods inherited from class com.github.akurilov.concurrent.coroutines.CoroutineBase

doStart, doStop, invoke

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 class java.lang.Object

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

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

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

Methods inherited from interface java.io.Closeable

close

Constructor Detail

ExclusiveCoroutineBase

protected ExclusiveCoroutineBase(CoroutinesExecutor executor)

ExclusiveCoroutineBase

protected ExclusiveCoroutineBase(CoroutinesExecutor executor,
                                 java.util.concurrent.locks.Lock invocationLock)

Method Detail

invokeTimed

protected final void invokeTimed(long startTimeNanos)

Description copied from class: CoroutineBase

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)

Specified by:

invokeTimed in class CoroutineBase

Parameters:

startTimeNanos - the time when the invocation started

invokeTimedExclusively

protected abstract void invokeTimedExclusively(long startTimeNanos)

The method is guaranteed to be executing only in a single thread.

Parameters:

startTimeNanos - the time when the invocation started