Skip to content

Commit 90476c2

Browse files
committed
Conditionally wrap Thread.sleep(..) call in collectResults(..).
Replace Thread.sleep(..) with Future.get(timeout, :TimeUnit) call for 1 millisecond. As such, the Future.isDone() (and Future.isCancelled()) calls are no longer necessary. Simply try to get the results, and if a TimeoutException is thrown, then simply set done to false. Add test coverage for ClusterCommandExecutor collectResults(..) method. Cleanup compiler warnings in ClusterCommandExecutorUnitTests. Closes spring-projects#2518
1 parent 7115f31 commit 90476c2

File tree

4 files changed

+676
-258
lines changed

4 files changed

+676
-258
lines changed

0 commit comments

Comments
 (0)