Package com.google.mu.util.concurrent
package com.google.mu.util.concurrent
Structured Concurrency
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.SPI Used by
ServiceLoaderto plug in the executor used byFanout.Plugin priority from low to high.Wraps anInterruptedException.