Как я могу запускать синхронные длительные операции в EventMachine без блокировки реактора?

Question

Я хотел бы запустить серию Proc s, в указанном порядке (то есть они не могут выполняться асинхронно). Некоторым из них может потребоваться сколько угодно времени.

Мой код работает в контексте реактора EventMachine. Существует ли известная идиома для написания такого кода без, блокирующего главный реактор?

Answer 1

Как сказал @maniacalrobot, используя EM.defer/deferrable, можно пропустить прок, не блокируя реактор. Но тогда вы вводите «callback hell», когда вам нужно последовательно запускать несколько procs.

Я знаю два решения, чтобы сделать код более читаемым: обещания и волокна.

Обещание дает хороший API сочинить асинхронные вызовы, есть много хороших статьи там, в том числе:

• http://domenic.me/2012/10/14/youre-missing-the-point-of-promises/
• http://www.html5rocks.com/en/tutorials/es6/promises/

волокон являются более рубиновый специфический инструмент, который заставляет ваш код выглядеть синхронно, делая асинхронные вещи.

Вот вспомогательный метод для выполнения процедурного асинхронно (отложенный), но по-прежнему блокировать код вызова без блокировки основного реактора (это магия Fibers):

def deferring(action) 
    f = Fiber.current 

    safe_action = proc do 
    begin 
     res = action.call 
     [nil, res] 
    rescue => e 
     [e, nil] 
    end 
    end 

    EM::defer(safe_action, proc { |error, result| f.resume([error, result]) }) 

    error, result = Fiber.yield 

    raise error if error 

    result 
end 

Пример использования:

action1_res = deferring(proc do 
    puts 'Async action 1' 
    42 
end 

begin 
    deferring(proc do 
    puts "Action1 answered #{action1_res}" 
    raise 'action2 failed' 
    end) 
rescue => error 
    puts error 
end 

Answer 2

Любой код, который обычно блокирует главный контур реактора, должен быть запущен с использованием EM#defer. EM#defer принимает два блока в качестве аргументов, первый блок запускается в другом потоке и не должен блокировать реактор. Можно передать второй, необязательный блок, который будет вызываться, когда первый завершит (он также получит результат первого блока).

Дальнейшее чтение https://github.com/eventmachine/eventmachine/wiki/EM::Deferrable-and-EM.defer

приведен пример цепочки 2 длинных запущенных операций будет выглядеть следующим образом:

logic_block = Proc.new { long_running_operation } 
callback = Proc.new { |long_running_operation_result| EM.defer next_long_running_operation } 

EM.defer logic_block, callback 

Осторожно, второй (обратный вызов) блок запускается на контуре реактора, так что если вы» планируйте объединение нескольких блоков кода с длинным ходом вместе, вам нужно будет снова вызвать EM.defer внутри обратных вызовов.