Package com.google.mu.util.concurrent

package com.google.mu.util.concurrent

Parallelizer (parallel stream using Executor), Retryer.

Package Specification

The code is developed and tested under Java 8.0.

Related Packages

Package	Description
com.google.mu.util	StringFormat, Substring, Optionals and more...
com.google.mu.util.graph	Stream-based incremental graph algorithms.
com.google.mu.util.stream	BiStream, BiCollector, MoreStreams, MoreCollectors etc.

Class	Description
Fanout	Supports structured concurrency for the common case where all concurrent operations are required (as if you are running them sequentially).
Fanout.Join2<A,B,R,X extends Throwable>	Function to join two results from concurrent computation.
Fanout.Join3<A,B,C,R,X extends Throwable>	Function to join three results from concurrent computation.
Fanout.Join4<A,B,C,D,R,X extends Throwable>	Function to join four results from concurrent computation.
Fanout.Join5<A,B,C,D,E,R,X extends Throwable>	Function to join five results from concurrent computation.
Parallelizer	Utility to support structured concurrency for IO-bound subtasks of a single unit of work, while limiting the max concurrency.
Retryer	Immutable object that retries actions upon exceptions.
Retryer.Delay<E>	Represents a delay upon an event of type E prior to the retry attempt.
Retryer.ForReturnValue<T>	Retries based on return values.
StructuredConcurrency	Deprecated. Use Fanout instead.
StructuredConcurrency.Join2<A,B,R,X extends Throwable>	Function to join two results from concurrent operations.
StructuredConcurrency.Join3<A,B,C,R,X extends Throwable>	Function to join three results from concurrent operations.
StructuredConcurrency.Join4<A,B,C,D,R,X extends Throwable>	Function to join four results from concurrent operations.
StructuredConcurrency.Join5<A,B,C,D,E,R,X extends Throwable>	Function to join five results from concurrent operations.
StructuredConcurrencyExecutorPlugin	SPI Used by ServiceLoader to plug in the executor used by Fanout.
StructuredConcurrencyExecutorPlugin.Priority	Plugin priority from low to high.