Плясов Климентий, ИТМО DWS, stage 5 #196
Conversation
# Conflicts: # src/main/java/ru/vk/itmo/test/klimplyasov/PlyasovServer.java # src/main/java/ru/vk/itmo/test/klimplyasov/PlyasovService.java # src/main/java/ru/vk/itmo/test/klimplyasov/Server.java
![codeclimate[bot]](https://avatars.githubusercontent.com/in/9403?s=60&v=4){kind=small}
src/main/java/ru/vk/itmo/test/klimplyasov/MergeHandleResult.java
Outdated
Show resolved
Hide resolved
| import java.lang.foreign.ValueLayout; | ||
| import java.nio.charset.StandardCharsets; | ||
|
|
||
| public final class ChunkGenerator { |
There was a problem hiding this comment.
ага, тут сразу в перемешку с 6ым стейджом, хорошо бы конечно разделить эти два PR
There was a problem hiding this comment.
Извините, случайно закоммитил в старый ПР
| HandleResult mergedResult = new HandleResult(HttpURLConnection.HTTP_GATEWAY_TIMEOUT, null); | ||
| int localValidCount = 0; | ||
| for (HandleResult handleResult : handleResults) { | ||
| if (handleResult.status() == HttpURLConnection.HTTP_OK |
There was a problem hiding this comment.
а тут NPE потенциальный, массив может заполняться не по порядку
| private void handleRemoteRequest(Request request, HttpSession session, String id) { | ||
| executorLocal.execute(() -> { | ||
| try { | ||
| HandleResult local = local(request, id); |
There was a problem hiding this comment.
ох мозг взрывается, вроде метод handleRemoteRequest, а внутри local()
There was a problem hiding this comment.
Видимо накосячил с названиями
| } | ||
| } | ||
|
|
||
| private void handleRejectedExecutionException(RejectedExecutionException executionException, HttpSession session) { | ||
| private CompletableFuture<HandleResult> handleRemoteAsync(final Request request, final String executorNode) { | ||
| return CompletableFuture.supplyAsync(() -> { |
There was a problem hiding this comment.
тут мы выполняем все в commonPool. Что плохо, лучше задать свой executor
|
|
||
| public class MergeHandleResult { | ||
| private static final Logger log = LoggerFactory.getLogger(MergeHandleResult.class); | ||
| private final HandleResult[] handleResults; |
There was a problem hiding this comment.
здесь могут быть проблемы в многопоточной среде, чтение/запись в массив идет из разных потоков. В таком случае просто final ссылка не поможет. Нужны какие-то примитивы синхронизации.
Подойдет как какая-нибудь потокобезопасная коллекция, так и AtomicReferenceArray
No description provided.