Б
почему - нет
ресурс освобождается сразу после того как элемент эмитится (если говорить про Mono), и после всех элементов (если речь о Flux)
Size: a a a
2020 September 22
D
то есть это что-то особенное должно быть
D
нетиповая задача
KS
не, я про набор примитивов конкарренси из тех же котиков
Конфиги перезагружаемые. У меня половина приложения это чтение конфига из рефа блин.
D
Oℕ
ресурс освобождается сразу после того как элемент эмитится (если говорить про Mono), и после всех элементов (если речь о Flux)
Uses a resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
w
Uses a resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
20/10!
KS
Мвары я супер активно использовал, когда писал поверх хазелькаста распределенные блокировки асинхронные.
VS
вот я говнокэши для токенов писал на атомиках + конкаррент хэш мэп
атомик если зафейлился обновить ведь блочит тред, да?
Oℕ
ресурс освобождается сразу после того как элемент эмитится (если говорить про Mono), и после всех элементов (если речь о Flux)
Ресурс на протяжении всего субскраюбера висит и освобождается, когда подписка завершается любым способом
VS
т.е. необернутый атомик в конкурентной среде вроде не самая дешевая штука
Oℕ
Освобождать ресурс сразу после эмита бессмысленно
Oℕ
Это всё равно что открыть файл и закрыть его до того, как флатмап отработает
AT
Это всё равно что открыть файл и закрыть его до того, как флатмап отработает
Уточняю
Б
Uses a resource, generated by a supplier for each individual Subscriber, while streaming the value from a Mono derived from the same resource and makes sure the resource is released if the sequence terminates or the Subscriber cancels.
Unlike in Flux, in the case of a valued Mono the cleanup happens just before passing the value to downstream
w
Unlike in Flux, in the case of a valued Mono the cleanup happens just before passing the value to downstream
А попа помыта?
KS
не, я про набор примитивов конкарренси из тех же котиков
Самый банальный пример, который мы делали сначала в тофу, потом это добавили в коты - пройтись по списку, обрабатывая его элементы параллельно, но не больше чем N элементов параллельно. 3 строки литеррали с семафором из котов.
Oℕ
Unlike in Flux, in the case of a valued Mono the cleanup happens just before passing the value to downstream
А оно принимает D => Mono[T]
Oℕ
Т.е. как раз брэкет получается
D
т.е. необернутый атомик в конкурентной среде вроде не самая дешевая штука
флаг для проверки был, там же помимо наличия в самой мапе, надо еще expiresAt чекать