我如何在Ruby中的陷阱上下文中使用Redis调用？

Question

我的脚本从redis数据库端获取元素,用它做一些工作.我需要确保如果脚本使用^ C或其他Signal完成,该元素将在数据库中返回.我正在努力做到这一点

require "redis"

class Test
  attr_reader :quit

  def initialize
    @redis = Redis.new
  end

  def trap_signal
    trap("INT") {
      puts "get ready to exit"
      @redis.rpush "TestQueue", @elem # I need to be sure that @emelent always puts back in the database 
      @quit = true}
  end

  def run!
    trap_signal
    @elem = "test string"
    @redis.rpush "TestQueue", @elem
    while !quit
      @redis.blpop "TestQueue", @elem
      # Do some work whith @element
      sleep 1
      # And put it back in the database 
      @redis.rpush "TestQueue", @elem
    end
  end

end

Test.new.run!

但得到这个错误

^Cget ready to exit
/usr/lib/ruby/2.1.0/monitor.rb:185:in `lock': can't be called from trap context (ThreadError)
    from /usr/lib/ruby/2.1.0/monitor.rb:185:in `mon_enter'
    from /usr/lib/ruby/2.1.0/monitor.rb:209:in `mon_synchronize'
    from /home/kusayu/.gem/ruby/2.1.0/gems/redis-3.2.0/lib/redis.rb:37:in `synchronize'
    from /home/kusayu/.gem/ruby/2.1.0/gems/redis-3.2.0/lib/redis.rb:991:in `rpush'
    from test.rb:13:in `block in trap_signal'
    from test.rb:24:in `call'
    from test.rb:24:in `sleep'
    from test.rb:24:in `run!'
    from test.rb:32:in `<main>'

Answer 1

@redis.rpush您的代码已经正常工作，只需从信号处理程序中删除即可。

您不应该在信号处理程序中运行“繁重”操作（无论如何您都会因此得到异常）。最好使用一个变量来向@quit = true主循环发出信号，表明该完成了，然后让主循环处理适当的清理工作。

因此，如果您只是从 INT 信号处理程序中删除@redis.rpush，那么您将确保该元素返回到数据库中，因为主循环只会完成一次@quitis true。