From ab24fb2504076a74fb5113bbcc7cf1a923387451 Mon Sep 17 00:00:00 2001 From: Ben Yu Date: Sun, 22 Dec 2024 14:43:39 -0800 Subject: [PATCH] withUnlimitedConcurrency() --- .../main/java/com/google/mu/util/concurrent/Fanout.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/mug/src/main/java/com/google/mu/util/concurrent/Fanout.java b/mug/src/main/java/com/google/mu/util/concurrent/Fanout.java index b03ea7d4e7..7f0976bb14 100644 --- a/mug/src/main/java/com/google/mu/util/concurrent/Fanout.java +++ b/mug/src/main/java/com/google/mu/util/concurrent/Fanout.java @@ -24,9 +24,10 @@ *

Any exception thrown by any of the concurrent operation will cancel all the other pending * operations and propagate back to the main thread. * - *

If the main thread is interrupted (when you use {@code concurrently()} to allow interruption), - * pending and currently running operations are canceled and the main thread will throw the - * unchecked {@link StructuredConcurrencyInterruptedException}. For example: + *

If the main thread is interrupted, pending and currently running operations are canceled and + * the main thread will throw the unchecked {@link StructuredConcurrencyInterruptedException}. + * + *

For example: * *

{@code
  * import static com.google.mu.util.concurrent.Fanout.concurrently;