A C D E 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(long, TimeUnit) - Method in interface com.github.akurilov.concurrent.AsyncRunnable

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

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.coroutine - package com.github.akurilov.concurrent.coroutine

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

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

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, Map<String, String>) - Constructor for class com.github.akurilov.concurrent.ContextAwareThreadFactory

ContextAwareThreadFactory(String, boolean, 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.coroutine

Base interface for all coroutines

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

The base class for all coroutines.

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

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

The coroutines executor.

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

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

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

CoroutinesExecutorTask(Queue<Coroutine>, boolean) - Constructor for class com.github.akurilov.concurrent.coroutine.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.coroutine.example.HelloWorldCoroutine

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

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

doClose() - Method in class com.github.akurilov.concurrent.coroutine.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.coroutine.CoroutineBase

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

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

E

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

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

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

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

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

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.coroutine.RoundRobinOutputCoroutine

H

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

Created by andrey on 23.08.17.

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

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

Created by andrey on 23.08.17.

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

I

IndexThrottle - Interface in com.github.akurilov.concurrent.throttle

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

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

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.coroutine.Coroutine

Perform the work

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

Decorates the invocation method with timing.

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

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

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

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

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

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

invokeTimedExclusively(long) - Method in class com.github.akurilov.concurrent.coroutine.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 - Class in com.github.akurilov.concurrent.coroutine.example

Created by andrey on 23.08.17.

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

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

N

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

O

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

Created by andrey on 29.08.17.

P

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

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

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

R

RateThrottle - Class in com.github.akurilov.concurrent.throttle

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

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

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

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.coroutine.RoundRobinOutputCoroutine

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

S

SequentialWeightsThrottle - Class in com.github.akurilov.concurrent.throttle

Created by kurila on 29.03.16.

SequentialWeightsThrottle(int[]) - Constructor for class com.github.akurilov.concurrent.throttle.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.coroutine.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

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.coroutine.CoroutinesExecutor

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.coroutine.CoroutinesExecutor

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

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

TIMEOUT_NANOS - Static variable in interface com.github.akurilov.concurrent.coroutine.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.coroutine

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.coroutine.TransferCoroutine

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

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

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

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

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

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

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

Request a permit about a thing

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

Request permits about a set of things

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 G H I M N O P R S T V