限制组合Ruby中的试验数量

require 'thread'

# 创建一个互斥锁
mutex = Mutex.new

# 定义一个方法，用于执行试验
def run_experiment(experiment_id)
  # 模拟试验执行时间
  sleep(rand(1..5))
  puts "Experiment #{experiment_id} finished"
end

# 定义试验数量
experiment_count = 10

# 定义最大并发数
max_concurrency = 3

# 创建一个线程池
pool = []

# 启动试验
experiment_count.times do |experiment_id|
  # 等待直到有可用的并发数
  mutex.synchronize do
    while pool.size >= max_concurrency
      sleep(0.1)
    end
  end

  # 创建一个新线程执行试验
  thread = Thread.new do
    run_experiment(experiment_id)
    mutex.synchronize do
      pool.delete(thread)
    end
  end

  # 将线程添加到线程池
  pool << thread
end

# 等待所有试验完成
pool.each(&:join)