多任务生产者消费者
"""
生产者 --> 消费者
生产者
1 生产者从中间件(kafka、mq、redis)中获取数据推送到queue中
2 事件通知并通知消费者线程开始消费
3 每次sleep 0.0001(防止 数据一直为空时占用大量资源)
消费者
1 事件消息接收到生产者消息开始消费
2 消费者在等待 timeout(s)后接受不到消息 wait 等待
Read More
moregeek program
【多线程】模拟阻塞队列,实现生产者消费者模型_perceus的博客-多极客编程
@TOC
生产者消费者模型
什么是阻塞队列
阻塞队列 与 普通队列 的特性一样的:先进先出。但是呢,相比于普通队列,阻塞队列也有着一些其它方面的功能!!!
线程安全
产生阻塞效果 2.1 如果队列为空,尝试出队一个元素,就会触发阻塞,一直阻塞到队列不为空为止。 2.2 如果队列为满,尝试入队一个元素,就会触发阻塞,一直阻塞到队列不为满为止。
基于上述特性,就可以实现“生产者消费者
Read More
Read More
第十二章-多线程#yyds干货盘点#-多极客编程
1 实现多线程
1.1 进程
进程: 是正在运行的程序
是系统进行资源分配和调用的独立单位
每一个进程都有它自己的内存空间和系统资源
1.2 线程
线程: 是进程中单个顺序流,是一条执行路径
单线程: 一个进程如果只有一条执行路径,则称为单线程程序
多线程: 一个进程如果有多条执行路径,则称为多线程程序
1.3 多线程的实现方式
方式1: 继承Thread类
定义一个类Demo继承Th
Read More
Read More