队列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')