在ruby中同步线程

Question

我想要多个线程同时触发所有的线程。

10.times do 
    Thread.new do 
    sleep rand(5)    # Initialize all the stuff 
    wait_for_all_other_threads # Wait for other threads to initialize their stuff 
    fire!      # Go. 
    end 
end 

我将如何实现wait_for_all_other_threads所以他们都fire!在同一时间？

Answer 1

使用屏障同步：http://rubygems.org/gems/barrier/

到屏障上的调用将导致每个线程阻塞，直到所有线程都要求它。

Answer 2

require "thread" 

N = 100 

qs = (0..1).map { Queue.new } 

t = 
    Thread.new(N) do |n| 
    n.times { qs[0].pop } 
    n.times { qs[1].push "" } 
    end 

ts = 
    (0..N-1).map do |i| 
    Thread.new do 
     sleep rand(5) # Initialize all the stuff 
     STDERR.puts "Init: #{i}" 
     qs[0].push "" 
     qs[1].pop  # Wait for other threads to initialize their stuff 
     STDERR.puts "Go: #{i}"  # Go. 
    end 
    end 
[t, *ts].map(&:join)