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

215 阅读 0 评论 142 点赞

我是靠谱客的博主沉静店员，这篇文章主要介绍ruby线程实现生产者消费者问题示例(队列Queue实现线程同步)，现在分享给大家，希望可以做个参考。

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线程的输出完成再关闭此进程