Ruby线程如何正确同步

在Ruby中，线程同步是一个重要的概念，因为它可以防止多个线程同时访问共享资源，从而导致数据不一致或其他问题。为了正确同步Ruby线程，你可以使用以下方法：

1. 使用Mutex（互斥锁）：

Mutex是Ruby中最常用的同步原语。它确保在同一时间只有一个线程可以访问共享资源。要使用Mutex，你需要创建一个Mutex对象，然后在需要同步的代码块中使用lock和unlock方法。

require 'thread'

mutex = Mutex.new

threads = []

10.times do
  threads << Thread.new do
    mutex.lock
    # 访问共享资源的代码
    puts "Thread #{Thread.current.object_id} is executing"
    sleep 1
    mutex.unlock
  end
end

threads.each(&:join)

2. 使用Semaphore（信号量）：

Semaphore是一种限制同时访问共享资源的线程数量的同步原语。要使用Semaphore，你需要创建一个Semaphore对象，并设置允许同时访问的最大线程数。然后，在需要同步的代码块中使用acquire和release方法。

require 'thread'

semaphore = Semaphore.new(3) # 允许最多3个线程同时访问

threads = []

10.times do
  threads << Thread.new do
    semaphore.acquire
    # 访问共享资源的代码
    puts "Thread #{Thread.current.object_id} is executing"
    sleep 1
    semaphore.release
  end
end

threads.each(&:join)

3. 使用ThreadGroup：

ThreadGroup允许你管理一组线程。你可以使用join方法等待组中的所有线程完成。虽然ThreadGroup本身不提供内置的同步机制，但你可以结合其他同步原语（如Mutex）来同步线程组中的线程。

require 'thread'

group = ThreadGroup.new
mutex = Mutex.new

10.times do
  group.add_thread(Thread.new do
    mutex.lock
    # 访问共享资源的代码
    puts "Thread #{Thread.current.object_id} is executing"
    sleep 1
    mutex.unlock
  end)
end

group.join

总之，为了正确同步Ruby线程，你需要根据具体需求选择合适的同步原语（如Mutex、Semaphore或ThreadGroup），并在访问共享资源时使用适当的锁定和解锁方法。