会员可以在此提问,百战程序员老师有问必答
对大家有帮助的问答会被标记为“推荐”
看完课程过来浏览一下别人提的问题,会帮你学得更全面
截止目前,同学们一共提了 132600个问题
Python 全系列/第十五阶段:Python 爬虫开发/docker 容器扩展(旧) 24498楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/网络编程(旧) 24500楼
Python 全系列/第十五阶段:Python 爬虫开发/爬虫反反爬 24501楼
JAVA 全系列/第九阶段:权限控制与安全认证/Shiro(旧) 24502楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 24503楼
JAVA 全系列/(旧的隐藏)第七阶段:JAVA 高级技术/Linux 24504楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/IO 流技术(旧) 24506楼
JAVA 全系列/第一阶段:JAVA 快速入门/变量、数据类型、运算符 24507楼
JAVA 全系列/第一阶段:JAVA 快速入门/变量、数据类型、运算符 24508楼

# coding=utf-8

import threading
import time
from queue import Queue

class Pro(threading.Thread):
    def run(self):
        global q
        count = 0
        while True:
            if q.qsize()<1000:
                for i in range(100):
                    count += 1
                    msg = "生产"+str(count)
                    q.put(msg) # 往队列中添加新产品
                    print(msg)
            time.sleep(1)


class Con(threading.Thread):
    def run(self):
        global q
        while True:
            if q.qsize() > 100:
                for i in range(150):
                    msg = self.name+"消费"+q.get()
                    print(msg)
            time.sleep(1)


if __name__ == '__main__':
    q = Queue() # 创建队列,线程中能使用
    for i in range(500): # 放500个初始产品
        q.put("初始产品"+str(i))
    for i in range(2): # 两个生产者
        p = Pro()
        p.start()
    for i in range(5):  # 五个消费者
        c = Con()
        c.start()

老师,我给生产者设置的遍历区间是range(100),给消费者设置的是range(150),为什么消费者不能消耗完队列里面的产品,程序一会在执行。还有就是为什么要放入初始500个产品。

Python 全系列/第三阶段:Python 网络与并发编程/并发编程 24509楼
JAVA 全系列/第二阶段:JAVA 基础深化和提高/容器(旧) 24510楼

课程分类

百战程序员微信公众号

百战程序员微信小程序

©2014-2025百战汇智(北京)科技有限公司 All Rights Reserved 北京亦庄经济开发区科创十四街 赛蒂国际工业园
网站维护:百战汇智(北京)科技有限公司
京公网安备 11011402011233号    京ICP备18060230号-3    营业执照    经营许可证:京B2-20212637