bug #IAJR32 修复在ParallelStrategyExecutor可能出现的NPE问题

This commit is contained in:
everywhere.z
2024-08-13 17:10:12 +08:00
parent 1b4d51580c
commit 086ecad3e3
3 changed files with 11 additions and 3 deletions

View File

@@ -17,7 +17,15 @@ public class CompletableFutureExpand {
return future;
}
return future.whenComplete(new Canceller(Delayer.delay(new Timeout<>(future, timeoutDefaultObj), timeout, unit)));
return future.whenComplete(
new Canceller(
Delayer.delay(
new Timeout<>(future, timeoutDefaultObj),
timeout,
unit
)
)
);
}
/**

View File

@@ -215,7 +215,7 @@ public abstract class ParallelStrategyExecutor {
return whenFutureObj;
} catch (InterruptedException | ExecutionException e) {
interrupted[0] = true;
return null;
return WhenFutureObj.fail("Unknown", e);
}
}).collect(Collectors.toList());

View File

@@ -39,7 +39,7 @@
</scm>
<properties>
<revision>2.12.2.2</revision>
<revision>2.12.2.3</revision>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<maven.compiler.source>8</maven.compiler.source>