Package com.google.mu.util.concurrent

package com.google.mu.util.concurrent

Structured Concurrency

Package Specification

Structured concurrency utilities (Parallelizer supports Java 8+; Fanout uses Java 21+ virtual threads by default or a custom StructuredConcurrencyExecutorPlugin).

Related Packages

Package	Description
com.google.mu.util	StringFormat, Substring, Optionals and more...
com.google.mu.util.concurrent24	Java 24 structured concurrency and gatherers (requires mug-concurrent24 artifact)
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.
StructuredConcurrencyExecutorPlugin	SPI Used by ServiceLoader to plug in the executor used by Fanout.
StructuredConcurrencyExecutorPlugin.Priority	Plugin priority from low to high.
StructuredConcurrencyInterruptedException	Wraps an InterruptedException.