生产消费者模型中的task_done()如何作用

这篇文章主要讲解了“生产消费者模型中的task_done()如何作用”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“生产消费者模型中的task_done()如何作用”吧！

tase_done()的作用：

只有消费者把队列所有的数据处理完毕，queue.join()才会停止阻塞

代码解释

#关于tase_done()的作用：只有消费者把队列所有的数据处理完毕，queue.join()才会停止阻塞import timefrom queue import Queuefrom threading import Threadq = Queue()def produce():    for i in range(10):        q.put(i)        print('生产：',i)    print('生产任务完毕！')    q.join()    print(produce.__name__,'函数结束！')def consumer():    for i in range(10):        print('消费：', q.get())        q.task_done()        # if i == 4:        #     print('休息1s...')        #     time.sleep(1)#sleep作用：查看生产者是否阻塞    print(consumer.__name__,'函数结束！')pro = Thread(target=produce)con = Thread(target=consumer)pro.start()con.start()con.join()print('消费者任务完成')pro.join()print('生产者任务完成')

生产： 0
生产： 1
生产： 2
生产： 3
生产： 4
生产： 5
消费： 0
消费： 1
消费： 2
消费： 3
消费： 4
消费： 5
生产： 6
生产： 7
生产：8
消费： 6
消费： 7
消费： 8
生产： 9
生产任务完毕！
消费： 9
consumer 函数结束！
produce 函数结束！
消费者任务完成
生产者任务完成

说明：生产任务已经完毕为什么没有直接produce函数结束？

说明这里产生了阻塞，产生阻塞的原因是因为消费者没有处理完生产者所有任务。

tase_done()的作用：只有消费者把队列所有的数据处理完毕，queue.join()才会停止阻塞所以才会有produce函数结束!然后生产任务结束。

对比解释看效果

注释掉q.task_done()和q.join()

#关于tase_done()的作用：只有消费者把队列所有的数据处理完毕，queue.join()才会停止阻塞import timefrom queue import Queuefrom threading import Threadq = Queue()def produce():    for i in range(10):        q.put(i)    print('生产任务完毕！')    # q.join()    # if i == 4:        #     print('休息1s...')        #     time.sleep(1)#sleep作用：查看生产者是否阻塞    print(produce.__name__,'函数结束！')def consumer():    for i in range(10):        print('消费：', q.get())        # q.task_done()    print(consumer.__name__,'函数结束！')pro = Thread(target=produce)con = Thread(target=consumer)pro.start()con.start()con.join()print('消费者任务完成')pro.join()print('生产者任务完成')

生产： 0
生产： 1
生产： 2
生产： 3
生产： 4
生产： 5
生产： 6
生产： 7
生产： 8
生产： 9
消费： 0
消费： 1
生产任务完毕！
produce 函数结束！
消费： 2
消费： 3
消费： 4
消费： 5
消费： 6
消费： 7
消费： 8
消费： 9
consumer 函数结束！
消费者任务完成
生产者任务完成

说明：不带task_done()和join()情况下生产任务结束，produce函数立刻结束，并没有等待消费者处理完所有任务立即结束。

仅注释掉q.task_done()**

#关于tase_done()的作用：只有消费者把队列所有的数据处理完毕，queue.join()才会停止阻塞import timefrom queue import Queuefrom threading import Threadq = Queue()def produce():    for i in range(10):        q.put(i)    print('生产任务完毕！')    q.join()    print(produce.__name__,'函数结束！')def consumer():    for i in range(10):        print('消费：', q.get())        # q.task_done()        # if i == 4:        #     print('休息1s...')        #     time.sleep(1)#sleep作用：查看生产者是否阻塞    print(consumer.__name__,'函数结束！')pro = Thread(target=produce)con = Thread(target=consumer)pro.start()con.start()con.join()print('消费者任务完成')pro.join()print('生产者任务完成')

生产： 0
生产： 1
生产： 2
生产： 3
生产： 4
生产： 5
生产： 6
生产： 7
生产： 8
生产： 9
生产任务完毕！
消费： 0
消费： 1
消费： 2
消费： 3
消费： 4
消费： 5
消费： 6
消费： 7
消费： 8
消费： 9
consumer 函数结束！
消费者任务完成
。。。阻塞。。。

说明：消费者已经把任务完成了，但是produce函数却一直阻塞没有结束。

感谢各位的阅读，以上就是“生产消费者模型中的task_done()如何作用”的内容了，经过本文的学习后，相信大家对生产消费者模型中的task_done()如何作用这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是编程网，小编将为大家推送更多相关知识点的文章，欢迎关注！