私のスクリプトは、redisデータベースの要素からいくつかの作業をしている要素を取得します。スクリプトが^ Cまたは他のシグナルで終了した場合、その要素はデータベースに返されることを確認する必要があります。 私はそれをRubyのトラップコンテキストでRedis呼び出しを使用するにはどうすればよいですか?
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!
を行うが、あなたのコードはすでにちょうどシグナルハンドラから@redis.rpush
を削除し、正常に動作
^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>'
あなたはトランザクションロックを参照していますか?はい、あなたはhttp://redis.io/topics/transactionsを読むべきです – kiddorails
@kiddorails私はトランザクションを使用しません、私はちょうど中断時にredis構造に私のアプリの現在の状態を保存する必要があります。このエラーは落胆しているようですが、なぜそれが起こるかわかりません。 – kusayu