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.-
ClassDescriptionSupports 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.Utility to support structured concurrency for IO-bound subtasks of a single unit of work, while limiting the max concurrency.Immutable object that retries actions upon exceptions.Represents a delay upon an event of typeEprior to the retry attempt.Retries based on return values.SPI Used byServiceLoaderto plug in the executor used byFanout.Plugin priority from low to high.Wraps anInterruptedException.