1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
#!/usr/bin/ruby
# -*- mode: ruby -*-
# $Id: prodcons.ruby,v 1.3 2005-06-10 00:57:22 igouy-guest Exp $
# http://www.bagley.org/~doug/shootout/
require 'thread'
def main(n)
mutex = Mutex.new
access = ConditionVariable.new
count = data = consumed = produced = 0
consumer = Thread.new do
i = 0
loop do
mutex.synchronize {
while count == 0 do access.wait(mutex) end
i = data
count = 0
access.signal
}
consumed += 1
if i == n then break end
end
end
producer = Thread.new do
for i in 1 .. n do
mutex.synchronize {
while count == 1 do access.wait(mutex) end
data = i
count = 1
access.signal
}
produced += 1
end
end
producer.join
consumer.join
puts "#{produced} #{consumed}"
end
main(Integer(ARGV.shift || 1))
|
