Skip to content

Commit

Permalink
Conditionally wrap Thread.sleep(..) call in collectResults(..).
Browse files Browse the repository at this point in the history 
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
  • Loading branch information
@jxblum
jxblum committed Sep 27, 2023
1 parent 7115f31 commit 90476c2
Show file tree
Hide file tree
Showing 4 changed files with 676 additions and 258 deletions.
Loading

0 comments on commit 90476c2

Please sign in to comment.