Ruby解释器When块执行后未续行及Redis订阅阻塞后续代码问题

嗨，我来帮你搞定这个问题！你遇到的核心问题其实很典型——Redis的subscribe方法是阻塞式的，一旦调用它，当前线程就会陷入无限循环，一直盯着指定频道的消息，除非你主动退出订阅，否则后面的代码根本没机会跑。

先拆解下你的代码问题 #

看你的on_complete方法，redis.subscribe之后的puts语句永远执行不到，就是因为订阅把线程卡死了：

def self.on_complete
  redis.subscribe('address_notifier') do |payload|
    on_post_execute payload
  end
  puts 'BUT WE NEVER GET HERE' # 被阻塞住，永远到不了这一步
end

怎么解决？把订阅丢去独立线程跑 #

最简单直接的办法，就是把阻塞的订阅逻辑放到一个单独的线程里执行，这样主线程就能继续往下走了。修改后的代码如下：

class Record < ActiveRecord::Base
  def self.import(params)
    perform_tasks params[:record]
    on_complete
  end

  def self.perform_tasks(record_params)
    record_params.each do |param|
      AddressWorker.perform_async param
    end
  end

  def self.on_complete
    # 新开一个线程处理Redis订阅，不阻塞主线程
    Thread.new do
      redis.subscribe('address_notifier') do |payload|
        on_post_execute payload
      end
    end
    puts 'NOW WE CAN REACH HERE!' # 现在终于能正常执行啦
  end
end

额外提醒 #

• 如果之后需要停止这个订阅线程，可以把线程实例保存下来，比如@subscription_thread = Thread.new { ... }，然后在合适的时机调用@subscription_thread.kill来终止它。
• 要是你用的是异步Redis客户端（比如redis-rb的异步模式），也可以用非阻塞的订阅方式，但线程方案对大多数场景来说都是最容易上手且有效的。

内容的提问来源于stack exchange，提问作者Daniel Viglione