Смирнов Андрей ИТМО КТ Stage 5 #181
Conversation
![codeclimate[bot]](https://avatars.githubusercontent.com/in/9403?s=60&v=4){kind=small}
src/main/java/ru/vk/itmo/test/smirnovandrew/RendezvousClusterManager.java
Show resolved
Hide resolved
| this.dao = new MyServerDao(dao); | ||
| this.executor = new MyExecutor(corePoolSize, availableProcessors); | ||
| this.logger = Logger.getLogger(MyServer.class.getName()); | ||
| this.httpClient = HttpClient.newHttpClient(); |
There was a problem hiding this comment.
На каком пуле потоков выполняются запросы к другим репликам?
There was a problem hiding this comment.
На том же, что задается вот в этой строчке
this.executor = new MyExecutor(corePoolSize, availableProcessors);
There was a problem hiding this comment.
Но ведь при создании HttpClient в него не передается никакой executor. Соответственно, будет создан отдельный вот тут
Или я что-то не заметил?
| }; | ||
|
|
||
| completableResults.forEach(completableFuture -> { | ||
| var responseFuture = completableFuture.whenComplete(whenComplete); |
There was a problem hiding this comment.
На каком пуле потоков выполняется агрегация ответов от реплик?
There was a problem hiding this comment.
На том же, что задается вот в этой строчке
this.executor = new MyExecutor(corePoolSize, availableProcessors);
There was a problem hiding this comment.
Так как в явном виде не меняется пул потоков (не передается другой executor), то будет выполняться на том же пуле потоков, что и completableResults, то есть на том же пуле, что и sendAsync, на потоках из httpClient.
| this.dao = new MyServerDao(dao); | ||
| this.executor = new MyExecutor(corePoolSize, availableProcessors); | ||
| this.logger = Logger.getLogger(MyServer.class.getName()); | ||
| this.httpClient = HttpClient.newHttpClient(); |
There was a problem hiding this comment.
Но ведь при создании HttpClient в него не передается никакой executor. Соответственно, будет создан отдельный вот тут
Или я что-то не заметил?
| }; | ||
|
|
||
| completableResults.forEach(completableFuture -> { | ||
| var responseFuture = completableFuture.whenComplete(whenComplete); |
There was a problem hiding this comment.
Так как в явном виде не меняется пул потоков (не передается другой executor), то будет выполняться на том же пуле потоков, что и completableResults, то есть на том же пуле, что и sendAsync, на потоках из httpClient.
build.gradle
Outdated
| @@ -68,8 +68,9 @@ compileTestJava { | |||
| options.compilerArgs += ["--enable-preview"] | |||
| } | |||
|
|
|||
| application { | |||
| mainClass = 'ru.vk.itmo.test.reference.ReferenceService' | |||
| run { | |||
There was a problem hiding this comment.
Надо откатить перед мерджем
No description provided.