在我的 rails 控制器方法中运行线程

Question

我有一组数据，我想在我的 rails 应用程序中进行一些计算，每个计算都是相互独立的，所以我想对它们进行线程化，这样我的响应速度会快得多。

这是我的 ATM：

def show

  @stats = Stats.new

  Thread.new {
    @stats.top_brands = #RESULT OF FIRST CALCULATION     
  }

  Thread.new {
    @stats.top_retailers = #RESULT OF SECOND CALCULATION
  }

  Thread.new {
    @stats.top_styles = #RESULT OF THIRD CALCULATION
  }

  Thread.new {
     @stats.top_colors = #RESULT OF FOURTH CALCULATION
  }

  render json: @stats
end

现在这会为@stats 的每个成员实例返回一堆空数组，但是，如果我将线程连接在一起，它会运行，但由于每个线程都阻塞，因此无法实现线程化的目的。

由于我对线程非常陌生，我想知道我在这里做错了什么，或者是否有可能完成我正在尝试做的事情，即并行运行 4 次计算并将结果返回到客户。

谢谢，

乔

Answer 1

这首先取决于您的计算是在执行处理器繁重的操作还是执行大量阻塞 IO，例如从数据库、文件系统或网络读取。如果他们做前者，那不会有太大的好处，因为每个线程都占用 CPU 时间，并且没有其他线程可以调度 - 更糟糕的是，即使您使用的是具有 Global Interpreter Lock 的 Ruby MRI。但是，如果线程正在执行阻塞 IO，它们至少可以等待，让另一个线程运行，等待，让另一个线程运行等等，直到它们全部返回。

最后，您必须将所有线程连接在一起，因为您需要它们的返回值。在所有 Thread.new 调用下执行此操作。将每个 Thread.new 的返回值保存到一个数组中：

threads = []
threads << Thread.new ...

然后在渲染之前将它们连接在一起：

threads.each &:join

如果您想真正确定这对您有帮助，只需对整个操作进行基准测试：

def show
  start_time = Time.now.to_f
  @stats = Stats.new

  Thread.new {
    @stats.top_brands = #RESULT OF FIRST CALCULATION     
  }
  Thread.new {
     @stats.top_colors = #RESULT OF FOURTH CALCULATION
  }

  @elapsed_time = Time.now.to_f - start_time
  # do something with @elapsed_time, like putsing it or rendering it in your response

  render json: @stats
end

希望对您有所帮助。