Module com.github.akurilov.concurrent

Package com.github.akurilov.concurrent

Interface AsyncRunnable

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

All Known Subinterfaces:

Coroutine, OutputCoroutine<T>

All Known Implementing Classes:

AsyncRunnableBase, CoroutineBase, CoroutinesExecutorTask, DaemonBase, ExclusiveCoroutineBase, HelloWorldCoroutine, HelloWorldExclusiveCoroutine, RoundRobinOutputCoroutine, TransferCoroutine

public interface AsyncRunnable
extends java.io.Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	AsyncRunnable.State

Method Summary

Modifier and Type	Method	Description
AsyncRunnable	await()	Wait while the state is STARTED
boolean	await(long timeout, java.util.concurrent.TimeUnit timeUnit)
boolean	isClosed()
boolean	isFinished()
boolean	isInitial()
boolean	isShutdown()
boolean	isStarted()
boolean	isStopped()
AsyncRunnable	shutdown()	Notify to stop to enqueue incoming requests.
AsyncRunnable	start()	Start/resume the execution
AsyncRunnable.State	state()
AsyncRunnable	stop()	Stop (with further resumption capability)

Methods inherited from interface java.io.Closeable

close

Method Detail

state

AsyncRunnable.State state()
                   throws java.rmi.RemoteException

Returns:

the current state, null if closed

Throws:

java.rmi.RemoteException

isInitial

boolean isInitial()
           throws java.rmi.RemoteException

Returns:

true if the state is "initial", false otherwise

Throws:

java.rmi.RemoteException

isStarted

boolean isStarted()
           throws java.rmi.RemoteException

Returns:

true if the state is "started", false otherwise

Throws:

java.rmi.RemoteException

isShutdown

boolean isShutdown()
            throws java.rmi.RemoteException

Returns:

true if the state is "shutdown", false otherwise

Throws:

java.rmi.RemoteException

isStopped

boolean isStopped()
           throws java.rmi.RemoteException

Returns:

true if the state is "stopped", false otherwise

Throws:

java.rmi.RemoteException

isFinished

boolean isFinished()
            throws java.rmi.RemoteException

Returns:

true if the state is "finished", false otherwise

Throws:

java.rmi.RemoteException

isClosed

boolean isClosed()
          throws java.rmi.RemoteException

Returns:

true if there's no state, false otherwise

Throws:

java.rmi.RemoteException

start

AsyncRunnable start()
             throws java.lang.IllegalStateException,
                    java.rmi.RemoteException

Start/resume the execution

Returns:

the same instance with state changed to STARTED if call was successful.

Throws:

java.lang.IllegalStateException - if the previous state is not INITIAL neither STOPPED

java.rmi.RemoteException

shutdown

AsyncRunnable shutdown()
                throws java.lang.IllegalStateException,
                       java.rmi.RemoteException

Notify to stop to enqueue incoming requests. The await method should be used after this to make sure that everything accepted before the shutdown is done.

Throws:

java.lang.IllegalStateException

java.rmi.RemoteException

stop

AsyncRunnable stop()
            throws java.lang.IllegalStateException,
                   java.rmi.RemoteException

Stop (with further resumption capability)

Returns:

the same instance with state changed to STOPPED if call was successful

Throws:

java.lang.IllegalStateException - if the previous state is not STARTED

java.rmi.RemoteException

await

AsyncRunnable await()
             throws java.lang.InterruptedException,
                    java.rmi.RemoteException

Wait while the state is STARTED

Returns:

the same instance

Throws:

java.lang.InterruptedException

java.rmi.RemoteException

await

boolean await(long timeout,
              java.util.concurrent.TimeUnit timeUnit)
       throws java.lang.InterruptedException,
              java.rmi.RemoteException

Throws:

java.lang.InterruptedException

java.rmi.RemoteException