Ruby 和 Redis，线程不处理命令

Question

我正在使用 redis 和 ruby​​ 并尝试在线程中发出 blpop，这样我就可以等待列表中的传入项。

问题是 blpop block 中的代码似乎从未被调用过。这是我正在运行的示例代码 (ruby 1.9.3):

require 'rubygems'
require 'redis'

def start_thread
  @thread = Thread.new do
    r = Redis.new
    r.blpop("test", 0) do |key, message|
      process_message(key, message)
    end
  end
  redis = Redis.new
  redis.rpush "test", "hello world"
end

def process_message(key, message)
  @message = "#{key} was sent #{message}"
end

start_thread
@thread.join
p @message

非常感谢任何帮助!

Answer 1

require 'rubygems'
require 'redis'

def start_thread
  @thread = Thread.new do
    r = Redis.new
    key, message = r.blpop(:test, 0)
    process_message(key, message)
  end
  redis = Redis.new
  redis.rpush :test, "hello world"
end

def process_message(key, message)
  @message = "#{key} was sent #{message}"
end

start_thread
@thread.join
p @message