队列Queue的get方法

写了一段生产者消费者模型的代码：

 from time import sleep

 from random import randint, random

 from multiprocessing import Process, Queue

 def consumer(q, name):

     while 1:

         if q.get() == 'stop' and q.qsize() == 0:

             break

         food = q.get()

         print('%s 吃了 %s' % (name, food))

         sleep(randint(1, 3))

 def producer(q, name, food):

     for i in range(10):

         sleep(random())

         foo = food + str(i)

         print("%s 拉了一坨 %s" % (name, foo))

         q.put(foo)

 if __name__ == '__main__':

     q = Queue(10)

     c = Process(target=consumer, args=(q, "老狗"))

     c.start()

     p1 = Process(target=producer, args=(q, '峰哥', '粑粑'))

     p1.start()

     p1.join()

     q.put('stop')

这段代码执行的结果是：

 峰哥 拉了一坨 粑粑0

 峰哥 拉了一坨 粑粑1

 老狗 吃了 粑粑1

 峰哥 拉了一坨 粑粑2

 峰哥 拉了一坨 粑粑3

 峰哥 拉了一坨 粑粑4

 老狗 吃了 粑粑3

 峰哥 拉了一坨 粑粑5

 老狗 吃了 粑粑5

 峰哥 拉了一坨 粑粑6

 峰哥 拉了一坨 粑粑7

 老狗 吃了 粑粑7

 峰哥 拉了一坨 粑粑8

 峰哥 拉了一坨 粑粑9

 老狗 吃了 粑粑9

发现只打印了奇数的产品，排错发现是逻辑出错了，应该先用food先从队列里面get，然后去判断，而上面这段代码的问题出在每次if判断从队列里面拿出来了一个导致的

下面是修改后的代码：

 from time import sleep

 from random import randint, random

 from multiprocessing import Process, Queue

 def consumer(q, name):

     while 1:

         food = q.get()

         if food == 'stop':

             break

         print('%s 吃了 %s' % (name, food))

         sleep(randint(1, 3))

 def producer(q, name, food):

     for i in range(10):

         sleep(random())

         foo = food + str(i)

         print("%s 拉了一坨 %s" % (name, foo))

         q.put(foo)

 if __name__ == '__main__':

     q = Queue(10)

     c = Process(target=consumer, args=(q, "老狗"))

     c.start()

     p1 = Process(target=producer, args=(q, '峰哥', '粑粑'))

     p1.start()

     p1.join()

     q.put('stop')

巴特西

队列Queue的get方法

最新文章

热门文章