com.github.akurilov.concurrent.coroutines

Class TransferCoroutine<T>

java.lang.Object

com.github.akurilov.concurrent.AsyncRunnableBase

com.github.akurilov.concurrent.coroutines.CoroutineBase

com.github.akurilov.concurrent.coroutines.ExclusiveCoroutineBase

com.github.akurilov.concurrent.coroutines.TransferCoroutine<T>

All Implemented Interfaces:

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

public class TransferCoroutine<T>
extends ExclusiveCoroutineBase
implements Coroutine

The exclusive coroutine implementation which tries to transfer the items from the given input to the given output. The items got from the input which may not be transferred to the output w/o blocking are stored to the deferred tasks buffer.

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

Constructor and Description
TransferCoroutine(CoroutinesExecutor executor, com.github.akurilov.commons.io.Input<T> input, com.github.akurilov.commons.io.Output<T> output, int batchSize)

Method Summary

Modifier and Type	Method and Description
protected void	doClose()
protected 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.ExclusiveCoroutineBase

invokeTimed

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, 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.coroutines.Coroutine

invoke

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

TransferCoroutine

public TransferCoroutine(CoroutinesExecutor executor,
                         com.github.akurilov.commons.io.Input<T> input,
                         com.github.akurilov.commons.io.Output<T> output,
                         int batchSize)

Method Detail

invokeTimedExclusively

protected final void invokeTimedExclusively(long startTimeNanos)

Description copied from class: ExclusiveCoroutineBase

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

Specified by:

invokeTimedExclusively in class ExclusiveCoroutineBase

Parameters:

startTimeNanos - the time when the invocation started

doClose

protected final void doClose()
                      throws java.io.IOException

Overrides:

doClose in class AsyncRunnableBase

Throws:

java.io.IOException