Package com.github.akurilov.concurrent.coroutines

Class RoundRobinOutputCoroutine<T,O extends com.github.akurilov.commons.io.Output<T>>

java.lang.Object

com.github.akurilov.concurrent.AsyncRunnableBase

com.github.akurilov.concurrent.coroutines.CoroutineBase

com.github.akurilov.concurrent.coroutines.RoundRobinOutputCoroutine<T,O>

All Implemented Interfaces:

com.github.akurilov.commons.io.Output<T>, AsyncRunnable, Coroutine, OutputCoroutine<T>, java.io.Closeable, java.lang.AutoCloseable

public final class RoundRobinOutputCoroutine<T,O extends com.github.akurilov.commons.io.Output<T>>
extends CoroutineBase
implements OutputCoroutine<T>

The coroutine implementation which acts like round robin output scattering the objects among the wrapped outputs.

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	Description
RoundRobinOutputCoroutine(CoroutinesExecutor executor, java.util.List<O> outputs, int buffCapacity)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
com.github.akurilov.commons.io.Input<T>	getInput()
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)
int	put(java.util.List<T> buffer)
int	put(java.util.List<T> srcBuff, int from, int to)
boolean	put(T ioTask)

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, doShutdown, isClosed, isFinished, isInitial, isShutdown, isStarted, isStopped, shutdown, start, state, stop

Methods inherited from interface java.io.Closeable

close

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

invoke

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

doStart, doStop, invoke

Methods inherited from class java.lang.Object

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

Constructor Detail

RoundRobinOutputCoroutine

public RoundRobinOutputCoroutine(CoroutinesExecutor executor,
                                 java.util.List<O> outputs,
                                 int buffCapacity)

Method Detail

put

public final boolean put(T ioTask)
                  throws java.io.IOException

Specified by:

put in interface com.github.akurilov.commons.io.Output<T>

Throws:

java.io.IOException

put

public final int put(java.util.List<T> srcBuff,
                     int from,
                     int to)
              throws java.io.IOException

Specified by:

put in interface com.github.akurilov.commons.io.Output<T>

Throws:

java.io.IOException

put

public final int put(java.util.List<T> buffer)
              throws java.io.IOException

Specified by:

put in interface com.github.akurilov.commons.io.Output<T>

Throws:

java.io.IOException

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

getInput

public final com.github.akurilov.commons.io.Input<T> getInput()

Specified by:

getInput in interface com.github.akurilov.commons.io.Output<T>

doClose

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

Overrides:

doClose in class AsyncRunnableBase

Throws:

java.io.IOException