Ruby Event Machine останавливает или убивает операцию дефиса

Question

Мне было интересно, могу ли я остановить выполнение операции, которая была дефферирована.

require 'rubygems' 
require 'em-websocket' 

EM.run do 
    EM::WebSocket.start(:host => '0.0.0.0', :port => 8080) do |ws| 
    ws.onmessage do |msg| 
     op = proc do 
     sleep 5 # Thread safe IO here that is safely killed 
     true 
     end 

     callback = proc do |result| 
     puts "Done!" 
     end 

     EM.defer(op, callback) 
    end 
    end 
end 

Это пример сервера веб-сокетов. Иногда, когда я получаю сообщение, я хочу сделать несколько ввода-вывода, позже может появиться другое сообщение, которое должно читать одно и то же, следующее всегда имеет приоритет над предыдущей. Поэтому я хочу отменить первый op и сделать второй.

Answer 1

Вот мое решение. Он похож на решение EM.queue, но просто использует хэш.

require 'rubygems' 
require 'em-websocket' 
require 'json' 

EM.run do 
    EM::WebSocket.start(:host => '0.0.0.0', :port => 3333) do |ws| 
    mutex = Mutex.new # to make thread safe. See https://github.com/eventmachine/eventmachine/blob/master/lib/eventmachine.rb#L981 
    queue = EM::Queue.new 
    ws.onmessage do |msg| 
     message_type = JSON.parse(msg)["type"] 
     op = proc do 
     mutex.synchronize do 
      if message_type == "preferred" 
      puts "killing non preferred\n" 
      queue.size.times { queue.pop {|thread| thread.kill } } 
      end 
      queue << Thread.current 
     end 

     puts "doing the long running process" 
     sleep 15 # Thread safe IO here that is safely killed 
     true 
     end 

     callback = proc do |result| 
     puts "Finished #{message_type} #{msg}" 
     end 

     EM.defer(op, callback) 
    end 
    end 
end