core.async

1зной

1ответ

NullPointerException in Storm при запуске топологии

Я получаю NullPointerException с помощью метода backtype.storm.utils.DisruptorQueue.consumeBatchToCursor при запуске моей топологии, в частности в болте. Резервуары выполнены надлежащим образом. Устра

2зной

1ответ

Состояния преобразователи в core.async

Im пытается понять, как сделать преобразователи состояния в core.async. Например, как я могу сделать преобразователь, который подсчитывает количество элементов, которые попадают в канал? Например, я х

3зной

1ответ

Каков самый простой способ периодически запускать задачу в clojure

Я хочу выполнить функцию каждые 10 секунд. Как сделать это самым простым способом? В core.async есть функция тайм-аута, которая в МОСТ будет ждать это время, и я хочу, чтобы это время подождали в МИН.

1зной

1ответ

Имеет ли размер буфера канала больше 0, необходимый для определенных типов генерируемых пользователем событий?

Если вы посмотрите на код для async webinar вы увидите, что некоторые каналы создаются с размером 1, но большинство из них размером 0. Размер 1 кажется, используется, когда два события могут прийти в

4зной

1ответ

Clojure core.async класть! против идти блокировать

Я прочитал эту замечательную статью о core.async здесь: http://www.core-async.info/reference/primitives Я изо всех сил, чтобы понять внутреннюю механику положить! и иди. Я так понимаю: ставим! являетс

5зной

1ответ

Как реализовать микробиблиотеку Skynet 1m с core.async?

Для того, чтобы попытаться понять core.async, я безуспешно пытался реализовать «Скайнет 1 млн microbenchmark», а именно: Создает актера (goroutine, что угодно), который порождает 10 новых актеров, каж