如何在线程或子进程中运行和停止delayed_jobs工作线程以进行测试

Question

我希望能够执行一些需要工作人员运行的测试。

为了实现这一点，创建了这个测试辅助方法：

def with_delayed_jobs
  t=Thread.new {Delayed::Worker.new.start}
  sleep(5)
  yield
  t.exit
end

所以我可以在我的测试中编写

with_delayed_jobs {
  ___test_content___
}

不幸的是，工作人员似乎不以这种方式运行。也许我可以通过流程来做到这一点。有人知道如何实现这一目标吗？

Answer 1

您可以使用以下命令运行作业表中当前的作业：

 Delayed::Worker.new(
          :max_priority => nil,
          :min_priority => nil,
          :quiet => true
        ).work_off

文档在这里，尽管它们很稀疏。