-
Notifications
You must be signed in to change notification settings - Fork 8
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Threads must wait to be ready #10
Conversation
Signed-off-by: olivier lamy <[email protected]>
@sbordet please have a look |
@@ -437,6 +440,8 @@ public void run( int transactionNumber ) | |||
} | |||
} | |||
|
|||
List<Future<Void>> futures = this.runnersExecutorService.invokeAll( callables ); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not good, invokeAll()
blocks until all tasks are complete.
@@ -139,25 +144,28 @@ private void handleResource( Resource resource ) | |||
// it's a group so we can request in parallel but wait all responses before next step | |||
ExecutorService executorService = Executors.newWorkStealingPool(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not sure why we want to create a new ExecutorService
here ? Can't we just use the existing one ?
Signed-off-by: olivier lamy <[email protected]>
Signed-off-by: olivier lamy <[email protected]>
Signed-off-by: olivier lamy <[email protected]>
fix for #8