AK
Может подскажете чатик, где могут помочь?
Size: a a a
2020 September 03
NG
Вторая проблема -- балансировщик по логике вещей должен дождаться всей картины для своей инициализации. А интерфейс completable future не очень удобен для комбинации фьюч, может есть реализация получше?
CompletableFuture.allOf не подойдёт?
SK
Вторая проблема -- балансировщик по логике вещей должен дождаться всей картины для своей инициализации. А интерфейс completable future не очень удобен для комбинации фьюч, может есть реализация получше?
У Spotify есть набор утилит для работы с CompletableFuture/CompletionStage
AK
CompletableFuture.allOf не подойдёт?
Мучаюсь с ним, он не предназначен для сбора результата. Есть конечно вариант скопировать код из jdk и написать свой allOf, но пока ищу другие варианты
AK
Stanislav Kashirin
У Spotify есть набор утилит для работы с CompletableFuture/CompletionStage
Спасибо, посмотрю
SK
Мучаюсь с ним, он не предназначен для сбора результата. Есть конечно вариант скопировать код из jdk и написать свой allOf, но пока ищу другие варианты
VP
Мучаюсь с ним, он не предназначен для сбора результата. Есть конечно вариант скопировать код из jdk и написать свой allOf, но пока ищу другие варианты
Почему не предназначен? Делаете allOf(), а внутри следущего шага get() у исходных фьюч.
AK
Я результат allOf хотел дальше прокинуть для инициализации балансировщика, но со вспомогательной фьючей можно и так да.
AK
Резолвить ее руками
AK
А что скажете насчёт обхода гонок при инициализации коннекшена? Может есть какая-то книга или бест практисес?
AK
Пример гонки: коннекшены прикопаны в какой-то структуре, а начальный момент она пуста, два треда могут пойти её инициализировать. Очевидное решение с захватом монитора на структуре кажется неправильным
DP
Пример гонки: коннекшены прикопаны в какой-то структуре, а начальный момент она пуста, два треда могут пойти её инициализировать. Очевидное решение с захватом монитора на структуре кажется неправильным
сорри, может задачу совсем не так понимаю, но разве обычного
AtomicBoolean вместе с его CAS-ом - тут не достаточно?AK
сорри, может задачу совсем не так понимаю, но разве обычного
AtomicBoolean вместе с его CAS-ом - тут не достаточно?Стейт машину предлагаешь с тремя состояниями? Я думал об этом, но у меня она уже есть внутри коннекшена, получается огород какой-то
SK
Пример гонки: коннекшены прикопаны в какой-то структуре, а начальный момент она пуста, два треда могут пойти её инициализировать. Очевидное решение с захватом монитора на структуре кажется неправильным
Два треда запускают асинхронный процесс инициализации?
AK
сорри, может задачу совсем не так понимаю, но разве обычного
AtomicBoolean вместе с его CAS-ом - тут не достаточно?И это разве не фейл-фаст решение, с обработкой ошибок на стороне клиента?
AK
Stanislav Kashirin
Два треда запускают асинхронный процесс инициализации?
Я захотел лейзи инициализацию тут
DP
Стейт машину предлагаешь с тремя состояниями? Я думал об этом, но у меня она уже есть внутри коннекшена, получается огород какой-то
Я имел ввиду, что можно взять
AtomicBoolean, и делать из потоков CAS - чей CAS прошел, тот и делает инициализациюSK
Можно через cas зайти в секцию запустить вычисление и записать на него фьючу
AK
Я имел ввиду, что можно взять
AtomicBoolean, и делать из потоков CAS - чей CAS прошел, тот и делает инициализациюНу это понятно, у меня так сделано внутри коннекшена
КХ
Мучаюсь с ним, он не предназначен для сбора результата. Есть конечно вариант скопировать код из jdk и написать свой allOf, но пока ищу другие варианты