-
Notifications
You must be signed in to change notification settings - Fork 12
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge remote-tracking branch 'origin/random-test-failures-oct2024'
- Loading branch information
Showing
5 changed files
with
534 additions
and
220 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,69 @@ | ||
| package org.janelia.saalfeldlab.n5; | ||
|
|
||
| import java.util.Optional; | ||
| import java.util.function.Supplier; | ||
|
|
||
| public class TestRunners { | ||
|
|
||
| public static <T> Optional<T> tryWaitRepeat(Supplier<T> supplier) throws InterruptedException { | ||
|
|
||
| return tryWaitRepeat(supplier, 5, 50, 2); | ||
| } | ||
|
|
||
| public static <T> Optional<T> tryWaitRepeat(Supplier<T> supplier, int nTries) throws InterruptedException { | ||
|
|
||
| return tryWaitRepeat(supplier, nTries, 50, 2); | ||
| } | ||
|
|
||
| public static <T> Optional<T> tryWaitRepeat(Supplier<T> supplier, int nTries, long waitTimeMillis) throws InterruptedException { | ||
|
|
||
| return tryWaitRepeat(supplier, nTries, waitTimeMillis, 2); | ||
| } | ||
|
|
||
| /** | ||
| * Attempts to execute a provided {@link Supplier} multiple times, with an increasing wait period | ||
| * between each attempt. If the supplier returns a non-null result, it is wrapped in an | ||
| * {@code Optional} and returned. If all attempts fail or return null, an empty {@link Optional} is returned. | ||
| * | ||
| * <p>The wait time between attempts increases after each failure, multiplied by a specified factor. | ||
| * | ||
| * @param <T> the type of result provided by the supplier | ||
| * @param supplier the {@link Supplier} function that provides the result to be evaluated. The | ||
| * function may throw a {@link RuntimeException} if it fails, which will be caught and retried. | ||
| * @param nTries the maximum number of attempts to invoke the supplier | ||
| * @param initialWaitTimeMillis the initial wait time in milliseconds before retrying after the first failure | ||
| * @param waitTimeMultiplier the multiplier to apply to the wait time after each failure, increasing | ||
| * the wait time for subsequent retries | ||
| * @return an {@link Optional} containing the result from the supplier if a non-null result is returned | ||
| * before the maximum number of tries, or an empty {@code Optional} if all attempts fail or | ||
| * return null | ||
| * @throws InterruptedException thrown if interrupted while waiting | ||
| */ | ||
| public static <T> Optional<T> tryWaitRepeat( | ||
| final Supplier<T> supplier, | ||
| final int nTries, | ||
| final long initialWaitTimeMillis, | ||
| final int waitTimeMultiplier) throws InterruptedException { | ||
|
|
||
| int i = 0; | ||
| long waitTime = initialWaitTimeMillis; | ||
| while (i < nTries) { | ||
|
|
||
| if (i == nTries) | ||
| break; | ||
|
|
||
| try { | ||
| T result = supplier.get(); | ||
| if (result != null) | ||
| return Optional.of(result); | ||
| } catch (RuntimeException e) {} | ||
|
|
||
| Thread.sleep(waitTime); | ||
| waitTime *= waitTimeMultiplier; | ||
| i++; | ||
| } | ||
|
|
||
| return Optional.empty(); | ||
| } | ||
|
|
||
| } |
Oops, something went wrong.