ruby线程实现生产者消费者问题示例(队列Queue实现线程同步)

Vevina ·
更新时间:2024-09-21
· 886 次阅读

Ruby线程实现经典的生产者消费者问题,用ruby中的Queue类实现线程同步问题。

代码如下:
require "thread" 
puts "ProAndCon" 
queue = Queue.new    #用队列Queue实现线程同步 
producer = Thread.new do 
    10.times do |i| 
        sleep rand(i) # 让线程睡眠一段时间 
        queue << i 
        puts "#{i} produced" 
    end 
end 
consumer = Thread.new do 
    10.times do |i| 
        value = queue.pop 
        sleep rand(i/2) 
        puts "consumed #{value}" 
    end 
end 
consumer.join  #等待consumer线程的输出完成再关闭此进程



线程同步 示例 Ruby

需要 登录 后方可回复, 如果你还没有账号请 注册新账号