Привет. У меня есть вопрос про ФТ и котовый IO.

Question

Пользователь 61918

Привет. У меня есть вопрос про ФТ и котовый IO.

Я слепил модель и написал для неё интерпретатор параметризованный cats.IO. Выглядит это примерно так:

case class Event(type: String, attribute: String, ...)
def eventGroup(e: Event): Int
trait Events[F[_]]{
def pollEvents(): F[Event]
def processEvent(evts: Set[Event]): F[Unit]
}

Проблема в том, что хочется сделать конкурентную обработку событий, но я не могу обрабатывать из разных потоков 2 и более евентов e с одинаковым
eventGroup(e)
.

У меня есть старый

class EventHandler {
def processEvent(e: Event): Unit
}

который делает необходимую синхронизацию. Его можно как-то переиспользовать для ФТ реализации? Или тут нужно в другую сторону посмотреть?

#programming #russian #scala

0

23.07.2018

1 ответов

2 просмотра

Oleg ℕižnik · Accepted Answer

Oleg ℕižnik

Мвар или семафор для синхронизации

0

23.07.2018

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

Привет. У меня есть вопрос про ФТ и котовый IO.

1 ответов

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