Index (helix-concurrency 0.4.0-SNAPSHOT API)

A B C E F G H I R S V W
All Classes and Interfaces|All Packages

A

awaitTermination(long, TimeUnit) - Method in class com.helixframework.concurrency.executor.HelixExecutorService

B

BatchFireForgetProcessor<T> - Class in com.helixframework.concurrency.processor: Abstract processor that can be used to implement async fire and forget messaging with batching.
BatchFireForgetProcessor() - Constructor for class com.helixframework.concurrency.processor.BatchFireForgetProcessor: Creates a new instance of FireForgetProcessor.
BatchFireForgetProcessor(int, int) - Constructor for class com.helixframework.concurrency.processor.BatchFireForgetProcessor: Creates a new instance of FireForgetProcessor.
BatchFireForgetProcessor(int, int, Duration, Duration) - Constructor for class com.helixframework.concurrency.processor.BatchFireForgetProcessor: Creates a new instance of FireForgetProcessor.

C

call() - Method in class com.helixframework.concurrency.executor.HelixCallable
cancel(boolean) - Method in class com.helixframework.concurrency.executor.HelixFuture
com.helixframework.concurrency.executor - package com.helixframework.concurrency.executor
com.helixframework.concurrency.processor - package com.helixframework.concurrency.processor
com.helixframework.concurrency.rwlock - package com.helixframework.concurrency.rwlock
consumer() - Method in class com.helixframework.concurrency.processor.BatchFireForgetProcessor: Gets the consumer function that will consume events sent to this processor.
consumer() - Method in class com.helixframework.concurrency.processor.FireForgetProcessor: Gets the consumer function that will consume events sent to this processor.

E

execute() - Method in interface com.helixframework.concurrency.rwlock.ValueOperation: Operation that returns a result.
execute() - Method in interface com.helixframework.concurrency.rwlock.VoidOperation: Operation that does not return a result.
execute(Runnable) - Method in class com.helixframework.concurrency.executor.HelixExecutorService

F

FireForgetProcessor<T> - Class in com.helixframework.concurrency.processor: Abstract processor that can be used to implement async fire and forget messaging.
FireForgetProcessor() - Constructor for class com.helixframework.concurrency.processor.FireForgetProcessor: Creates a new instance of FireForgetProcessor.
FireForgetProcessor(int) - Constructor for class com.helixframework.concurrency.processor.FireForgetProcessor: Creates a new instance of FireForgetProcessor.
FireForgetProcessor(int, Duration) - Constructor for class com.helixframework.concurrency.processor.FireForgetProcessor: Creates a new instance of FireForgetProcessor.

G

get() - Method in class com.helixframework.concurrency.executor.HelixFuture
get(long, TimeUnit) - Method in class com.helixframework.concurrency.executor.HelixFuture
getName() - Method in class com.helixframework.concurrency.processor.BatchFireForgetProcessor: Gets the name of this processor.
getName() - Method in class com.helixframework.concurrency.processor.FireForgetProcessor: Gets the name of this processor.
getName() - Method in class com.helixframework.concurrency.rwlock.ReadWriteLocked: Gets the name of the lock.
getName() - Method in class com.helixframework.concurrency.rwlock.ReadWriteStripedLocked: Returns the name of this instance.
getShutdownBehavior() - Method in interface com.helixframework.concurrency.processor.ShutdownBehaviorAware: Determines the shutdown behavior based on the system property "helix.fireforget.immediate-shutdown".
GRACEFUL - Enum constant in enum class com.helixframework.concurrency.processor.ShutdownBehavior

H

HelixCallable<V> - Class in com.helixframework.concurrency.executor: Callable that copies the current HelixContext and MDC from the calling thread onto the executing thread.
HelixCallable(Callable<V>) - Constructor for class com.helixframework.concurrency.executor.HelixCallable
HelixExecutorService - Class in com.helixframework.concurrency.executor: Executor service that copies the current HelixContext onto underlying pooled threads.
HelixExecutorService(ExecutorService) - Constructor for class com.helixframework.concurrency.executor.HelixExecutorService: Wraps the supplied ExecutorService with a Helix Context aware executor.
HelixFuture<V> - Class in com.helixframework.concurrency.executor: Future that copies the current HelixContext and MDC from the calling thread onto the executing thread.
HelixFuture(Future<V>) - Constructor for class com.helixframework.concurrency.executor.HelixFuture
HelixRunnable - Class in com.helixframework.concurrency.executor: Runnable that copies the HelixContext and MDC from the calling thread onto the executing thread.
HelixRunnable(Runnable) - Constructor for class com.helixframework.concurrency.executor.HelixRunnable

I

IMMEDIATE - Enum constant in enum class com.helixframework.concurrency.processor.ShutdownBehavior
invokeAll(Collection<? extends Callable<T>>) - Method in class com.helixframework.concurrency.executor.HelixExecutorService
invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class com.helixframework.concurrency.executor.HelixExecutorService
invokeAny(Collection<? extends Callable<T>>) - Method in class com.helixframework.concurrency.executor.HelixExecutorService
invokeAny(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class com.helixframework.concurrency.executor.HelixExecutorService
isCancelled() - Method in class com.helixframework.concurrency.executor.HelixFuture
isDone() - Method in class com.helixframework.concurrency.executor.HelixFuture
isRunning() - Method in class com.helixframework.concurrency.processor.BatchFireForgetProcessor
isRunning() - Method in class com.helixframework.concurrency.processor.FireForgetProcessor
isShutdown() - Method in class com.helixframework.concurrency.executor.HelixExecutorService
isTerminated() - Method in class com.helixframework.concurrency.executor.HelixExecutorService

R

read(ValueOperation<T>) - Method in class com.helixframework.concurrency.rwlock.ReadWriteLocked: Executes the read operation with a lock.
read(VoidOperation) - Method in class com.helixframework.concurrency.rwlock.ReadWriteLocked: Executes the read operation with a lock.
read(Object, ValueOperation<T>) - Method in class com.helixframework.concurrency.rwlock.ReadWriteStripedLocked: Executes a read operation under a read lock for the given key.
read(Object, VoidOperation) - Method in class com.helixframework.concurrency.rwlock.ReadWriteStripedLocked: Executes a read operation under a read lock for the given key.
ReadWriteLocked - Class in com.helixframework.concurrency.rwlock: Executes operations with read and write locks.
ReadWriteLocked() - Constructor for class com.helixframework.concurrency.rwlock.ReadWriteLocked: Creates a lock.
ReadWriteLocked(String) - Constructor for class com.helixframework.concurrency.rwlock.ReadWriteLocked: Creates a named lock.
ReadWriteStripedLocked - Class in com.helixframework.concurrency.rwlock: A thread-safe utility class that provides striped read-write locking capabilities.
ReadWriteStripedLocked() - Constructor for class com.helixframework.concurrency.rwlock.ReadWriteStripedLocked: Creates a new instance with no name.
ReadWriteStripedLocked(String) - Constructor for class com.helixframework.concurrency.rwlock.ReadWriteStripedLocked: Creates a new instance with the specified name.
run() - Method in class com.helixframework.concurrency.executor.HelixRunnable

S

shutdown() - Method in class com.helixframework.concurrency.executor.HelixExecutorService
ShutdownBehavior - Enum Class in com.helixframework.concurrency.processor
ShutdownBehaviorAware - Interface in com.helixframework.concurrency.processor: A marker interface that provides the ability to determine a component's shutdown behavior.
shutdownNow() - Method in class com.helixframework.concurrency.executor.HelixExecutorService
start() - Method in class com.helixframework.concurrency.processor.BatchFireForgetProcessor
start() - Method in class com.helixframework.concurrency.processor.FireForgetProcessor
stop() - Method in class com.helixframework.concurrency.processor.BatchFireForgetProcessor
stop() - Method in class com.helixframework.concurrency.processor.FireForgetProcessor
stop(Runnable) - Method in class com.helixframework.concurrency.processor.BatchFireForgetProcessor
stop(Runnable) - Method in class com.helixframework.concurrency.processor.FireForgetProcessor
submit(Runnable) - Method in class com.helixframework.concurrency.executor.HelixExecutorService
submit(Runnable, T) - Method in class com.helixframework.concurrency.executor.HelixExecutorService
submit(Callable<T>) - Method in class com.helixframework.concurrency.executor.HelixExecutorService
submit(T) - Method in class com.helixframework.concurrency.processor.BatchFireForgetProcessor: Submits an event to the processor.
submit(T) - Method in class com.helixframework.concurrency.processor.FireForgetProcessor: Submits an event to the processor.

V

valueOf(String) - Static method in enum class com.helixframework.concurrency.processor.ShutdownBehavior: Returns the enum constant of this class with the specified name.
ValueOperation<T> - Interface in com.helixframework.concurrency.rwlock: Operation with a return value.
values() - Static method in enum class com.helixframework.concurrency.processor.ShutdownBehavior: Returns an array containing the constants of this enum class, in the order they are declared.
VoidOperation - Interface in com.helixframework.concurrency.rwlock: Operation with no return value.

W

write(ValueOperation<T>) - Method in class com.helixframework.concurrency.rwlock.ReadWriteLocked: Executes the write operation with a lock.
write(VoidOperation) - Method in class com.helixframework.concurrency.rwlock.ReadWriteLocked: Executes the write operation with a lock.
write(Object, ValueOperation<T>) - Method in class com.helixframework.concurrency.rwlock.ReadWriteStripedLocked: Executes a write operation under a write lock for the given key.
write(Object, VoidOperation) - Method in class com.helixframework.concurrency.rwlock.ReadWriteStripedLocked: Executes a write operation under a write lock for the given key.

A B C E F G H I R S V W
All Classes and Interfaces|All Packages