Ruby 的 IO::Buffer 是一个面向字节缓冲区的高效容器，它在处理网络数据、文件映射和二进制协议时非常有用。与普通的字符串不同，IO::Buffer 提供了更精细的内存控制和并发原语，其中 lock_for_reading 和 lock_for_writing 就是两个重要的同步方法。它们实现的是典型的共享读锁与独占写锁语义，能有效协调多个线程对同一缓冲区的访问。
一、IO::Buffer 锁模型的基础
IO::Buffer 的锁机制借鉴了操作系统读写锁的设计思路。读锁也叫共享锁，它允许多个线程同时读取数据，前提是没有线程持有写锁。写锁也叫独占锁，一旦某个线程获得了写锁，其他线程既不能写也不能读，必须等待写锁释放。这种设计在大量读操作、少量写操作的场景下能够显著提升并发性能，因为读线程之间不会互相阻塞。
从互斥关系来看，可以把它理解为一个简单的规则：读锁和读锁可以共存；读锁和写锁不能共存；写锁和写锁也不能共存。这意味着只要有一个线程在写入缓冲区，所有读和写都必须等待。反之，即便有多个线程正在读取，只要没有写操作，它们就可以并行执行。这种特性使得 IO::Buffer 适合作为线程间共享的数据容器。
需要特别注意的是，IO::Buffer 的锁只对当前进程内的线程有效，它并不能跨进程提供保护。如果多个 Ruby 进程通过共享内存或文件映射同时操作同一个缓冲区，还需要借助文件锁或其他进程间同步机制。另外，锁的释放必须与获取严格配对，否则容易造成锁泄漏或死锁。
二、lock_for_reading 的共享读锁用法
lock_for_reading 用于申请共享读锁。当线程打算从缓冲区读取数据且不希望被写操作打断时，就可以调用这个方法。多个线程可以同时获得读锁，它们可以安全地读取相同的字节内容，而不用担心某个线程在写一半时被读取到不一致的状态。获取读锁后，缓冲区内的数据在锁释放前对其他读线程可见，但任何写线程都会被阻塞。
下面是一个基本的读锁示例。第一个例子使用块形式，块执行结束后读锁自动释放；第二个例子使用非块形式，需要手动调用 unlock 释放锁。
require 'io/buffer'
buffer = IO::Buffer.new(64)
buffer.set_string('ruby io buffer', 0)
# 块形式：自动释放读锁
buffer.lock_for_reading do
data = buffer.get_string(0, 14)
puts data
end
# 非块形式：需要手动释放
buffer.lock_for_reading
begin
data = buffer.get_string(0, 14)
puts data
ensure
buffer.unlock
end
块形式是最推荐的用法，因为即使块内抛出异常，锁也会在块退出时被可靠释放。非块形式虽然更灵活，但必须配合 ensure 来保证异常路径下也能调用 unlock。如果忘记释放读锁，后续的写操作会一直阻塞，导致线程死锁。
读锁的一个典型应用场景是多个工作线程读取同一个配置缓冲区。只要配置没有被修改，所有线程都可以并行读取，完全不需要串行化，这比用互斥锁包裹整个读取过程要高效得多。
三、lock_for_writing 的独占写锁用法
lock_for_writing 申请的是独占写锁。一旦线程拿到写锁，其他任何线程都不能再获取读锁或写锁，直到当前线程释放写锁。这种排他性保证了写入过程的原子性，读线程不会看到写入了一半的脏数据，其他写线程也不会交叉覆盖。对于需要修改缓冲区内容的任务，写锁是必要的保护。
下面是一个写入示例，它展示了多个线程竞争写入缓冲区时，写锁如何保证每次写入都完整地覆盖指定区域。
require 'io/buffer'
buffer = IO::Buffer.new(64)
threads = 4.times.map do |i|
Thread.new do
buffer.lock_for_writing do
buffer.set_string("writer-#{i}", 0)
sleep 0.01
end
end
end
threads.each(&:join)
puts buffer.get_string(0, 12).inspect
在上面的代码中，四个线程同时尝试写入缓冲区。由于 lock_for_writing 的独占性，同一时刻只有一个线程能进入写入块，其他线程在锁外等待。最终缓冲区中保留的是最后一个获得写锁的线程写入的内容，而不是多个字符串混乱拼接的结果。若去掉写锁，多个 set_string 调用可能交错执行，产生不可预期的字节内容。
与读锁一样，写锁也支持块形式和非块形式。推荐使用块形式，原因同样是异常安全和自动释放。在实际开发中，写入操作往往比读取操作更短，因此写锁的持有时间应尽量缩短，避免阻塞其他线程。对于较大的缓冲区修改，可以考虑先拷贝数据、在锁外处理，再一次性写回，从而减少锁粒度。
四、锁的释放、异常安全与常见陷阱
除了块形式的自动释放外，IO::Buffer 还提供了 unlock 方法用于手动释放锁。手动释放时必须保证 unlock 与 lock_for_reading 或 lock_for_writing 严格配对，否则会抛出异常或导致锁状态错误。块形式之所以更安全，是因为它在内部使用了 ensure 机制，无论正常返回还是抛出异常，锁都会被释放。
一个常见的陷阱是在持有读锁的块内部尝试获取写锁。由于读锁和写锁互斥，当前线程无法在持有读锁的同时获得写锁，这会造成死锁，程序会一直卡住。下面是一个错误示范。
require 'io/buffer'
buffer = IO::Buffer.new(64)
buffer.set_string('data', 0)
buffer.lock_for_
IO_Bufferlock_for_readinglock_for_writing修改时间：2026-08-13 05:31:59