Module com.aoapps.concurrent

Package com.aoapps.concurrent

Class ConcurrentUtils

java.lang.Object

com.aoapps.concurrent.ConcurrentUtils

public abstract class ConcurrentUtils
extends Object

Concurrency utilities.

Method Summary

Modifier and Type	Method	Description
static <E> List<E>	getAll(Iterable<? extends Future<? extends E>> futures)	Gets all of the results of the futures, returning a modifiable list of the results.
static <E,C extends Collection<E>> C	getAll(Iterable<? extends Future<? extends E>> futures, C output)	Gets all of the results of the futures into the provided collection.
static <K,V> Map<K,V>	getAll(Map<? extends K,? extends Future<? extends V>> futures)	Gets all of the results of the futures, returning a modifiable map of the results.
static <K,V,M extends Map<K,V>> M	getAll(Map<? extends K,? extends Future<? extends V>> futures, M output)	Gets all of the results of the futures into the provided map.
static void	waitForAll(Iterable<? extends Future<?>> futures)	Waits for all futures to complete, discarding any results.

Methods inherited from class java.lang.Object

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

Method Detail

waitForAll

public static void waitForAll(Iterable<? extends Future<?>> futures)
                       throws InterruptedException,
                              ExecutionException

Waits for all futures to complete, discarding any results. Note: This method is cloned to IntegerRadixSort.java to avoid package dependency.

Throws:

InterruptedException

ExecutionException

getAll

public static <E> List<E> getAll(Iterable<? extends Future<? extends E>> futures)
                          throws InterruptedException,
                                 ExecutionException

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

Throws:

InterruptedException

ExecutionException

getAll

public static <E,C extends Collection<E>> C getAll(Iterable<? extends Future<? extends E>> futures,
                                                         C output)
                                                  throws InterruptedException,
                                                         ExecutionException

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

Returns:

the collection that was given

Throws:

InterruptedException

ExecutionException

getAll

public static <K,V> Map<K,V> getAll(Map<? extends K,? extends Future<? extends V>> futures)
                                         throws InterruptedException,
                                                ExecutionException

Gets all of the results of the futures, returning a modifiable map of the results. The map will maintain the iteration order of the source.

Throws:

InterruptedException

ExecutionException

getAll

public static <K,V,M extends Map<K,V>> M getAll(Map<? extends K,? extends Future<? extends V>> futures,
                                                                  M output)
                                                           throws InterruptedException,
                                                                  ExecutionException

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

Returns:

the map that was given

Throws:

InterruptedException

ExecutionException