thread.join阻塞主线程

您只需将线程累积到另一个容器中,然后 join 它们一个接一个地被创建:

my_threads = []
for i in 1..100 do
    puts "Creating thread #{i}"
    my_threads << Thread.new(i) do |j|
        sleep 1
        puts "Thread #{j} done"
    end
end
puts "#{Thread.list.size} threads"

my_threads.each do |t|
    t.join
end

您也不能将线程绑定到 i 变量,因为 我 不断被覆盖,您的输出将是100行“线程100完成”;相反,您必须将其绑定到 我 我已经聪明地命名了 j .

您需要在循环之外连接线程。

for i in 1..100 do
  puts "Creating thread #{i}"
  t = Thread.new(i) do |mi|
    sleep 1
    puts "Thread #{mi} done"
  end
end

# Wait for all threads to end
Thread.list.each do |t|
  # Wait for the thread to finish if it isn't this thread (i.e. the main thread).
  t.join if t != Thread.current
 end