Ruby：基于哈希的内存和线程安全缓冲区？
|
我正在Redis支持的库中实现一种写/存储缓冲区，以将多个“ 0”调用压缩为一个调用。缓冲区必须是完全原子的，并且可以跨多个线程工作。
因此，我是处理线程安全的新手。是否有任何现有的库或标准化的方法来实现在线程环境中运行良好的全局基于哈希的缓冲区/队列？
例如，缓冲区散列的工作方式类似于此伪代码：
buffer #=> { :ident1 => { :value_a => 1, :value_b => 4 },
# :ident2 => { :value_a => 2, :value_b => 3 } }
buffer[:ident1][:value_a] #=> 1
# saving merges and increments {:value_a => 2} into buffer[:ident1]
save(:ident1, {:value_a => 2})
buffer[:ident1][:value_a] #=> 3
save
save
没有找到相关结果
已邀请:
1 个回复
墩瓣茅械
$buffer = {} $bufflock = Mutex.new threads = (0..2).map do |i| Thread.new do puts \"Starting Thread #{i}\" 3.times do puts \"Thread #{i} got: #{$buffer[:foo].inspect}\" $bufflock.synchronize{ $buffer[:foo] = ($buffer[:foo] || 1) * (i+1) } sleep rand end puts \"Ending Thread #{i}\" end end threads.each{ |t| t.join } # Wait for all threads to complete #=> Starting Thread 0 #=> Thread 0 got: nil #=> Starting Thread 1 #=> Thread 1 got: 1 #=> Starting Thread 2 #=> Thread 2 got: 2 #=> Thread 1 got: 6 #=> Thread 1 got: 12 #=> Ending Thread 1 #=> Thread 0 got: 24 #=> Thread 2 got: 24 #=> Thread 0 got: 72 #=> Thread 2 got: 72 #=> Ending Thread 0 #=> Ending Thread 2