A C D E F G H I M N O P R S T V

A

AnyNotNullSharedFutureTaskBase<V> - Class in com.github.akurilov.concurrent

Created by kurila on 15.09.16.

AnyNotNullSharedFutureTaskBase(AtomicReference<V>, CountDownLatch) - Constructor for class com.github.akurilov.concurrent.AnyNotNullSharedFutureTaskBase

AsyncRunnable - Interface in com.github.akurilov.concurrent

AsyncRunnable.State - Enum in com.github.akurilov.concurrent

AsyncRunnableBase - Class in com.github.akurilov.concurrent

AsyncRunnableBase() - Constructor for class com.github.akurilov.concurrent.AsyncRunnableBase

await() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

Wait while the state is STARTED

await() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

await(long, TimeUnit) - Method in interface com.github.akurilov.concurrent.AsyncRunnable

await(long, TimeUnit) - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

C

cancel(boolean) - Method in class com.github.akurilov.concurrent.AnyNotNullSharedFutureTaskBase

close() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

close() - Method in class com.github.akurilov.concurrent.DaemonBase

closeAll() - Static method in class com.github.akurilov.concurrent.DaemonBase

com.github.akurilov.concurrent - package com.github.akurilov.concurrent

com.github.akurilov.concurrent.coroutines - package com.github.akurilov.concurrent.coroutines

com.github.akurilov.concurrent.coroutines.example - package com.github.akurilov.concurrent.coroutines.example

ContextAwareThread(Runnable, String, boolean, Thread.UncaughtExceptionHandler, Map<String, String>) - Constructor for class com.github.akurilov.concurrent.ContextAwareThreadFactory.ContextAwareThread

ContextAwareThreadFactory - Class in com.github.akurilov.concurrent

Created by andrey on 23.08.17.

ContextAwareThreadFactory(String, boolean, Map<String, String>) - Constructor for class com.github.akurilov.concurrent.ContextAwareThreadFactory

ContextAwareThreadFactory(String, Map<String, String>) - Constructor for class com.github.akurilov.concurrent.ContextAwareThreadFactory

ContextAwareThreadFactory.ContextAwareThread - Class in com.github.akurilov.concurrent

Coroutine - Interface in com.github.akurilov.concurrent.coroutines

Base interface for all coroutines

CoroutineBase - Class in com.github.akurilov.concurrent.coroutines

The base class for all coroutines.

CoroutineBase(CoroutinesExecutor) - Constructor for class com.github.akurilov.concurrent.coroutines.CoroutineBase

CoroutinesExecutor - Class in com.github.akurilov.concurrent.coroutines

The coroutines executor.

CoroutinesExecutor() - Constructor for class com.github.akurilov.concurrent.coroutines.CoroutinesExecutor

CoroutinesExecutor(boolean) - Constructor for class com.github.akurilov.concurrent.coroutines.CoroutinesExecutor

CoroutinesExecutorTask - Class in com.github.akurilov.concurrent.coroutines

CoroutinesExecutorTask(Queue<Coroutine>, boolean) - Constructor for class com.github.akurilov.concurrent.coroutines.CoroutinesExecutorTask

D

DaemonBase - Class in com.github.akurilov.concurrent

Modifies the async runnable to make sure that all instances are closed by the special method.

DaemonBase() - Constructor for class com.github.akurilov.concurrent.DaemonBase

daemonFlag - Variable in class com.github.akurilov.concurrent.ContextAwareThreadFactory

doClose() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

doClose() - Method in class com.github.akurilov.concurrent.coroutines.example.HelloWorldCoroutine

doClose() - Method in class com.github.akurilov.concurrent.coroutines.example.HelloWorldExclusiveCoroutine

doClose() - Method in class com.github.akurilov.concurrent.coroutines.RoundRobinOutputCoroutine

doClose() - Method in class com.github.akurilov.concurrent.coroutines.TransferCoroutine

doShutdown() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

doStart() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

doStart() - Method in class com.github.akurilov.concurrent.coroutines.CoroutineBase

doStop() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

doStop() - Method in class com.github.akurilov.concurrent.coroutines.CoroutineBase

E

exceptionHandler - Static variable in class com.github.akurilov.concurrent.ContextAwareThreadFactory

ExclusiveCoroutineBase - Class in com.github.akurilov.concurrent.coroutines

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

ExclusiveCoroutineBase(CoroutinesExecutor) - Constructor for class com.github.akurilov.concurrent.coroutines.ExclusiveCoroutineBase

ExclusiveCoroutineBase(CoroutinesExecutor, Lock) - Constructor for class com.github.akurilov.concurrent.coroutines.ExclusiveCoroutineBase

F

FINISHED - com.github.akurilov.concurrent.AsyncRunnable.State

G

get() - Method in class com.github.akurilov.concurrent.AnyNotNullSharedFutureTaskBase

get(long, TimeUnit) - Method in class com.github.akurilov.concurrent.AnyNotNullSharedFutureTaskBase

getHardwareThreadCount() - Static method in class com.github.akurilov.concurrent.ThreadUtil

getInput() - Method in class com.github.akurilov.concurrent.coroutines.RoundRobinOutputCoroutine

H

HelloWorldCoroutine - Class in com.github.akurilov.concurrent.coroutines.example

Created by andrey on 23.08.17.

HelloWorldCoroutine(CoroutinesExecutor) - Constructor for class com.github.akurilov.concurrent.coroutines.example.HelloWorldCoroutine

HelloWorldExclusiveCoroutine - Class in com.github.akurilov.concurrent.coroutines.example

Created by andrey on 23.08.17.

HelloWorldExclusiveCoroutine(CoroutinesExecutor) - Constructor for class com.github.akurilov.concurrent.coroutines.example.HelloWorldExclusiveCoroutine

I

IndexThrottle - Interface in com.github.akurilov.concurrent

InitCallable<V> - Interface in com.github.akurilov.concurrent

A Callable which can be initialized and should be initialized before being invoked.

INITIAL - com.github.akurilov.concurrent.AsyncRunnable.State

Initializable - Interface in com.github.akurilov.concurrent

Something what may be initialized once

InitRunnable - Interface in com.github.akurilov.concurrent

A Runnable which can be initialized and should be initialized before being invoked.

invoke() - Method in interface com.github.akurilov.concurrent.coroutines.Coroutine

Perform the work

invoke() - Method in class com.github.akurilov.concurrent.coroutines.CoroutineBase

Decorates the invocation method with timing.

invokeTimed(long) - Method in class com.github.akurilov.concurrent.coroutines.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)

invokeTimed(long) - Method in class com.github.akurilov.concurrent.coroutines.example.HelloWorldCoroutine

invokeTimed(long) - Method in class com.github.akurilov.concurrent.coroutines.ExclusiveCoroutineBase

invokeTimed(long) - Method in class com.github.akurilov.concurrent.coroutines.RoundRobinOutputCoroutine

invokeTimedExclusively(long) - Method in class com.github.akurilov.concurrent.coroutines.example.HelloWorldExclusiveCoroutine

invokeTimedExclusively(long) - Method in class com.github.akurilov.concurrent.coroutines.ExclusiveCoroutineBase

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

invokeTimedExclusively(long) - Method in class com.github.akurilov.concurrent.coroutines.TransferCoroutine

isCancelled() - Method in class com.github.akurilov.concurrent.AnyNotNullSharedFutureTaskBase

isClosed() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

isClosed() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

isDone() - Method in class com.github.akurilov.concurrent.AnyNotNullSharedFutureTaskBase

isFinished() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

isFinished() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

isInitial() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

isInitial() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

isInitialized() - Method in interface com.github.akurilov.concurrent.Initializable

isShutdown() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

isShutdown() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

isStarted() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

isStarted() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

isStopped() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

isStopped() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

M

main(String...) - Static method in class com.github.akurilov.concurrent.coroutines.example.Main

Main - Class in com.github.akurilov.concurrent.coroutines.example

Created by andrey on 23.08.17.

Main() - Constructor for class com.github.akurilov.concurrent.coroutines.example.Main

N

newThread(Runnable) - Method in class com.github.akurilov.concurrent.ContextAwareThreadFactory

O

OutputCoroutine<T> - Interface in com.github.akurilov.concurrent.coroutines

Created by andrey on 29.08.17.

P

put(List<T>) - Method in class com.github.akurilov.concurrent.coroutines.RoundRobinOutputCoroutine

put(List<T>, int, int) - Method in class com.github.akurilov.concurrent.coroutines.RoundRobinOutputCoroutine

put(T) - Method in class com.github.akurilov.concurrent.coroutines.RoundRobinOutputCoroutine

R

RateThrottle - Class in com.github.akurilov.concurrent

A semaphore-like non-blocking throttle which permits at the given rate.

RateThrottle(double) - Constructor for class com.github.akurilov.concurrent.RateThrottle

RoundRobinOutputCoroutine<T,O extends com.github.akurilov.commons.io.Output<T>> - Class in com.github.akurilov.concurrent.coroutines

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

RoundRobinOutputCoroutine(CoroutinesExecutor, List<O>, int) - Constructor for class com.github.akurilov.concurrent.coroutines.RoundRobinOutputCoroutine

run() - Method in class com.github.akurilov.concurrent.coroutines.CoroutinesExecutorTask

S

SequentialWeightsThrottle - Class in com.github.akurilov.concurrent

Created by kurila on 29.03.16.

SequentialWeightsThrottle(int[]) - Constructor for class com.github.akurilov.concurrent.SequentialWeightsThrottle

set(V) - Method in class com.github.akurilov.concurrent.AnyNotNullSharedFutureTaskBase

setException(Throwable) - Method in class com.github.akurilov.concurrent.AnyNotNullSharedFutureTaskBase

setThreadCount(int) - Method in class com.github.akurilov.concurrent.coroutines.CoroutinesExecutor

shutdown() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

Notify to stop to enqueue incoming requests.

shutdown() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

SHUTDOWN - com.github.akurilov.concurrent.AsyncRunnable.State

start() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

Start/resume the execution

start() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

start(Coroutine) - Method in class com.github.akurilov.concurrent.coroutines.CoroutinesExecutor

STARTED - com.github.akurilov.concurrent.AsyncRunnable.State

state - Variable in class com.github.akurilov.concurrent.AsyncRunnableBase

state() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

state() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

stop() - Method in interface com.github.akurilov.concurrent.AsyncRunnable

Stop (with further resumption capability)

stop() - Method in class com.github.akurilov.concurrent.AsyncRunnableBase

stop(Coroutine) - Method in class com.github.akurilov.concurrent.coroutines.CoroutinesExecutor

STOPPED - com.github.akurilov.concurrent.AsyncRunnable.State

T

threadContext - Variable in class com.github.akurilov.concurrent.ContextAwareThreadFactory.ContextAwareThread

threadContext - Variable in class com.github.akurilov.concurrent.ContextAwareThreadFactory

threadNamePrefix - Variable in class com.github.akurilov.concurrent.ContextAwareThreadFactory

threadNumber - Variable in class com.github.akurilov.concurrent.ContextAwareThreadFactory

ThreadUtil - Class in com.github.akurilov.concurrent

Created by kurila on 09.09.15.

ThreadUtil() - Constructor for class com.github.akurilov.concurrent.ThreadUtil

Throttle - Interface in com.github.akurilov.concurrent

Throttle can make a decision about the specified thing to pass or to wait.

TIMEOUT_NANOS - Static variable in interface com.github.akurilov.concurrent.coroutines.Coroutine

The soft limit for the coroutine invocation duration.

toString() - Method in class com.github.akurilov.concurrent.ContextAwareThreadFactory

TransferCoroutine<T> - Class in com.github.akurilov.concurrent.coroutines

The exclusive coroutine implementation which tries to transfer the items from the given input to the given output.

TransferCoroutine(CoroutinesExecutor, Input<T>, Output<T>, int) - Constructor for class com.github.akurilov.concurrent.coroutines.TransferCoroutine

tryAcquire() - Method in class com.github.akurilov.concurrent.RateThrottle

tryAcquire() - Method in interface com.github.akurilov.concurrent.Throttle

Request a permit about a thing

tryAcquire(int) - Method in interface com.github.akurilov.concurrent.IndexThrottle

tryAcquire(int) - Method in class com.github.akurilov.concurrent.RateThrottle

tryAcquire(int) - Method in class com.github.akurilov.concurrent.SequentialWeightsThrottle

tryAcquire(int) - Method in interface com.github.akurilov.concurrent.Throttle

Request permits about a set of things

tryAcquire(int, int) - Method in interface com.github.akurilov.concurrent.IndexThrottle

tryAcquire(int, int) - Method in class com.github.akurilov.concurrent.SequentialWeightsThrottle

V

valueOf(String) - Static method in enum com.github.akurilov.concurrent.AsyncRunnable.State

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.github.akurilov.concurrent.AsyncRunnable.State

Returns an array containing the constants of this enum type, in the order they are declared.

A C D E F G H I M N O P R S T V