Index

A C E G K N R S T W
All Classes and Interfaces|All Packages

A

addListener(L, boolean) - Method in class com.aoapps.concurrent.ConcurrentListenerManager

Adds a listener.

C

call(R) - Method in interface com.aoapps.concurrent.Callback

The method called for the callback.

callAll(Collection<? extends Callable<? extends T>>) - Method in interface com.aoapps.concurrent.Executor

Calls all of the tasks concurrently, waiting for them to all complete.

Callback<R> - Interface in com.aoapps.concurrent

A callback that can be registered for asynchronous operation results.

close() - Method in class com.aoapps.concurrent.ConcurrentListenerManager

When no longer needed, close should be called to free resources.

close() - Method in class com.aoapps.concurrent.Executors

Closes this executor service instance.

com.aoapps.concurrent - module com.aoapps.concurrent

com.aoapps.concurrent - package com.aoapps.concurrent

ConcurrencyLimiter<K,R> - Class in com.aoapps.concurrent

Deprecated.

Please use either KeyedConcurrencyReducer or ConcurrencyReducer.

ConcurrencyLimiter() - Constructor for class com.aoapps.concurrent.ConcurrencyLimiter

Deprecated.

ConcurrencyReducer<R> - Class in com.aoapps.concurrent

Limits the concurrency to a resource.

ConcurrencyReducer() - Constructor for class com.aoapps.concurrent.ConcurrencyReducer

ConcurrentListenerManager<L> - Class in com.aoapps.concurrent

Provides per-listener event queues, and fires off events concurrently across listeners, but in-order per listener.

ConcurrentListenerManager() - Constructor for class com.aoapps.concurrent.ConcurrentListenerManager

ConcurrentListenerManager.Event<L> - Interface in com.aoapps.concurrent

The event callback.

ConcurrentUtils - Class in com.aoapps.concurrent

Concurrency utilities.

createCall(L) - Method in interface com.aoapps.concurrent.ConcurrentListenerManager.Event

Creates the Runnable that will call the event callback on the given listener.

E

enqueueEvent(ConcurrentListenerManager.Event<? super L>) - Method in class com.aoapps.concurrent.ConcurrentListenerManager

Enqueues a new event to all listener event queues.

execute(Runnable) - Method in interface com.aoapps.concurrent.Executor

executeSerialized(Callable<? extends R>) - Method in class com.aoapps.concurrent.ConcurrencyReducer

Executes a callable at most once.

executeSerialized(K, Callable<? extends R>) - Method in class com.aoapps.concurrent.KeyedConcurrencyReducer

Executes a callable at most once for the given key.

Executor - Interface in com.aoapps.concurrent

Extends Executor with additional features.

Executors - Class in com.aoapps.concurrent

Provides a central set of executors for use by any number of projects.

Executors() - Constructor for class com.aoapps.concurrent.Executors

Create a new instance of the executor service.

ExecutorServiceShutdownHook - Class in com.aoapps.concurrent

The threads of executor services can cause a JVM to keep running if they are not daemon threads.

ExecutorServiceShutdownHook(ExecutorService) - Constructor for class com.aoapps.concurrent.ExecutorServiceShutdownHook

Creates a new shutdown hook.

ExecutorServiceShutdownHook(ExecutorService, long, TimeUnit) - Constructor for class com.aoapps.concurrent.ExecutorServiceShutdownHook

Creates a new shutdown hook.

ExecutorServiceShutdownHook(ExecutorService, String) - Constructor for class com.aoapps.concurrent.ExecutorServiceShutdownHook

Creates a new shutdown hook.

ExecutorServiceShutdownHook(ExecutorService, String, long, TimeUnit) - Constructor for class com.aoapps.concurrent.ExecutorServiceShutdownHook

Creates a new shutdown hook.

G

getAll(Iterable<? extends Future<? extends E>>) - Static method in class com.aoapps.concurrent.ConcurrentUtils

Gets all of the results of the futures, returning a modifiable list of the results.

getAll(Iterable<? extends Future<? extends E>>, C) - Static method in class com.aoapps.concurrent.ConcurrentUtils

Gets all of the results of the futures into the provided collection.

getAll(Map<? extends K, ? extends Future<? extends V>>) - Static method in class com.aoapps.concurrent.ConcurrentUtils

Gets all of the results of the futures, returning a modifiable map of the results.

getAll(Map<? extends K, ? extends Future<? extends V>>, M) - Static method in class com.aoapps.concurrent.ConcurrentUtils

Gets all of the results of the futures into the provided map.

getPerProcessor() - Method in class com.aoapps.concurrent.Executors

An executor service that will execute at most two tasks per processor on multi-CPU systems or one task on single-CPU systems.

getPreferredConcurrency() - Method in class com.aoapps.concurrent.Executors

Gets the preferred concurrency for this executor.

getSequential() - Method in class com.aoapps.concurrent.Executors

A sequential implementation of executor that performs no concurrent processing.

getUnbounded() - Method in class com.aoapps.concurrent.Executors

Gets the unbounded executor.

K

KeyedConcurrencyReducer<K,R> - Class in com.aoapps.concurrent

Limits the concurrency to a resource identified by any arbitrary key object.

KeyedConcurrencyReducer() - Constructor for class com.aoapps.concurrent.KeyedConcurrencyReducer

N

newInstance() - Static method in class com.aoapps.concurrent.Executors

Deprecated.

Just use constructor directly. Subclasses are now allowed, too.

R

removeListener(L) - Method in class com.aoapps.concurrent.ConcurrentListenerManager

Removes a listener.

run() - Method in class com.aoapps.concurrent.ExecutorServiceShutdownHook

runAll(Collection<? extends Runnable>) - Method in interface com.aoapps.concurrent.Executor

Runs all of the tasks concurrently, waiting for them to all complete.

S

submit(Runnable) - Method in interface com.aoapps.concurrent.Executor

Submits to the executor.

submit(Runnable, long) - Method in interface com.aoapps.concurrent.Executor

Submits to the executor after the provided delay.

submit(Runnable, T) - Method in interface com.aoapps.concurrent.Executor

Submits to the executor, returning the provided value on success.

submit(Runnable, T, long) - Method in interface com.aoapps.concurrent.Executor

Submits to the executor after the provided delay, returning the provided value on success.

submit(Callable<? extends T>) - Method in interface com.aoapps.concurrent.Executor

Submits to the executor.

submit(Callable<? extends T>, long) - Method in interface com.aoapps.concurrent.Executor

Submits to the executor after the provided delay.

T

toString() - Method in class com.aoapps.concurrent.Executors

W

waitForAll(Iterable<? extends Future<?>>) - Static method in class com.aoapps.concurrent.ConcurrentUtils

Waits for all futures to complete, discarding any results.

wrap(Runnable) - Method in class com.aoapps.concurrent.Executors

Wraps the task with any other necessary tasks to prepare or cleanup for the task.

wrap(Callable<T>) - Method in class com.aoapps.concurrent.Executors

Wraps the task with any other necessary tasks to prepare or cleanup for the task.

A C E G K N R S T W
All Classes and Interfaces|All Packages