当块完成执行时，ruby 解释器不会继续执行下一条指令

Question

我有以下执行顺序。当 import 被调用时，它会依次调用 perform_tasks，然后在 on_complete 上进入 redis 订阅循环：

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

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

  def self.on_complete
    redis.subscribe('address_notifier') do |payload|
      on_post_execute payload
    end
    puts 'BUT WE NEVER GET HERE'
  end

  def self.on_post_execute(payload)
   puts 'Yes we get here'
  end
end

问题是当块完成执行，并且 on_post_execute 运行时，执行不会离开块。而且我们从不排队：

puts 'BUT WE NEVER GET HERE'

我们为什么不到达块后面的那一行？

请注意，使用 ruby​​ redis gem 中的redis.subscribe 在这里应该无关紧要，因为我到达了块，它是一个常规的 ruby​​ 块。

Answer 1

正如您所指出的，redis.subscribe 的使用在这里并不是完全不相关的。

此方法是 loop，在您 unsubscribe 之前不会中断。因此，在这种情况下，我认为您实际上并没有退出该块，因此您的 puts 行不会被执行。

  def self.on_complete
    redis.subscribe_with_timeout(5, 'address_notifier') do |payload|
      on_post_execute payload

      redis.unsubscribe
    end
    puts 'Should get here now'
  end

  def self.on_post_execute(payload)
    puts 'Yes we get here'
  end

或者使用subscribe_with_timeout:

  def self.on_complete
    redis.subscribe_with_timeout(5, 'address_notifier') do |payload|
      on_post_execute payload
    end
    puts 'Should get here now'
  end

  def self.on_post_execute(payload)
    puts 'Yes we get here'
  end