在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)