Привет всем! Надеюсь на помощь) Пытаюсь понять Future и как можно

Question

Привет всем! Надеюсь на помощь) Пытаюсь понять Future и как можно

использовать.
Идея как хотелось бы сделать: есть стрим, который бежит и в мапу копим stateful состояние стрима, можно ли сделать параллельный процес который будет брать эту мапу с состоянием, писать ее куда надо, но чтобы на это время записи чтение стрима не остановилось, а продолжало собирать stateful мапу
А по завершению записи паралелльной функции она опять брала мапу и записывала и так бесконечно
Это можно вообще сделать?

#programming #russian #scala

0

15.12.2021

4 ответов

16 просмотров

Evgenii Kuznetcov

нужно fs2/zio-strems, можно имплементировать на стандартных комбинаторах, без Ref. Вручную на футурах будет немного тяжко

0

15.12.2021

Simon

Самый тупой способ - держать мапу неизменяемой и при создании каждой новой мапы - менять ссылку на последнюю версию в AtomicReference. В параллельном потоке в цикле читать и на каждое изменение писать куда надо. Способ несколько умнее - в качестве стрима использовать akka stream, одним шагом аггрегировать мапу и отдавать новое состояние далье, следующим шагом писать. Между шагами - async и дропающий буфер. Способ несколько лучше - fs2/zio-stream с соответствующими механизмами там.

0

15.12.2021

Evgenii Kuznetcov

Evgenii Kuznetcov
нужно fs2/zio-strems, можно имплементировать на ст...

даже мапу не обязательно мутабельной делать

0

15.12.2021

Daniel · Accepted Answer

Daniel

https://typelevel.org/cats-effect/docs/std/ref

0

15.12.2021

169 похожих чатов

Привет всем! Надеюсь на помощь) Пытаюсь понять Future и как можно

4 ответов

Похожие вопросы