Вызов EventMachine отложить в обратном вызове?

Question

Я использую EventMachine.defer для обработки некоторых длительных процессов (неопределенное ожидание ответа от внешнего приложения). Я хочу сделать это в цикле: каждый раз, когда приложение отвечает, я обрабатываю ответ и сразу же хочу начать ждать следующего ответа.

Мой код в настоящее время выглядит следующим образом:

def watch_for_songs_change 
    EM.defer(
    ->(){ `mpc idle playlist` }, # wait for the song list to change 
    ->(_){ update_songs; watch_for_songs_change } 
) 
end 

я понял, что это звонит defer изнутри обратного вызова из defer. Действительно ли это? Я порождаю один поток изнутри другого и в конечном итоге закончим потоки? Или EventMachine вызывает обратный вызов после того, как он вернул поток в пул?

Answer 1

Я пытался связать вызовы, подобные этому ранее, в EM, и обнаружил, что использование периодических таймеров - это, как правило, лучший дизайн.

@timer = EventMachine.add_periodic_timer(1) { `mpc idle playlist` and update_songs }