如何调用多个进程

Question

我可以使用一些帮助在这个，给出这个代码:

result1, result2, result3 = do_stuff {
  method_1
  method_2
  method_3
}

我希望能够编写一个名为do_stuff的方法，可以单独调用该块的每一行，并返回每行/块的结果。这能做到吗?我是不是走错路了?像这样的东西(根本不起作用)是我想的。

def do_stuff(&block)
  block.each_block do |block|
    block.call
  end
end

编辑:我想要完成的是能够并行运行方法"do_stuff"内的每个方法/块调用(在它自己的线程中)，并且还在每个方法调用周围添加一些日志。

Answer 1

我同意上面的观点，你应该解释一下你要做什么，因为可能有一个更合适的模式可以使用。

顺便说一句，你可以做你想做的事，只要做一个小小的改变:

result1, result2 = do_stuff {
  [
    method_1,
    method_2,
    method_3
  ]
}

或者，也许更优雅一点，不用block:

result1, result2 = [
  method_1,
  method_2,
  method_3
]

:)

Answer 2

好的，问题更新后看起来更清楚了。您可以这样做，使用method_missing、instance_eval和threads:

class Parallelizer
  class << self
    def run(receiver, &block)
      @receiver = receiver
      instance_eval &block
      # wait for all threads to finish
      @threads.each{|t| t.join}
      @results
    end
    def method_missing *args, &block
      @threads ||= []
      @results ||= []
      @threads.push Thread.new{
        # you could add here custom wrappings
        @results.push(@receiver.send(*args, &block))
      }
    end
  end
end
class Test
  def take_a_break name, sec
    puts "#{name} taking a break for #{sec} seconds"
    Kernel.sleep sec
    puts "#{name} done."
    name
  end
end
t = Test.new
results = Parallelizer.run(t) do
  take_a_break 'foo', 3
  take_a_break 'bar', 2
  take_a_break 'baz', 1
end

要小心，但是，这并没有经过良好的测试，我不确定如何线程安全。