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
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	Convenient utilities to help with structured concurrency on top of an ExecutorService (preferably with virtual threads).
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.