有界缓冲问题有n个生产者和m个消费者，连接在一个有k个单位缓冲区的有界缓冲上。其中，pi和cj都是并发进程，只要缓冲区未满，生产者pi生产的产品就可投入缓冲区；只要缓冲区不空，消费者进程cj就可从缓冲区取走并消耗产品。 模型： int k; //k个单位的缓冲区 typedef anyitem it ...
分类：
其他好文 时间：
2020-04-29 23:24:49
阅读次数：
78
一、ReactiveX 与 RxJava ReactiveX 的全称为Reactive Extension，一般缩写为 Rx，即我们平常所说的反应式编程。其设计原理主要使用了观察者模式，区分数据的生产者和消费者，通过事件流的方式进行数据的异步处理。 RxJava 是 ReactiveX Java语言 ...
分类：
编程语言 时间：
2020-04-27 17:14:00
阅读次数：
69
Kafka 属于分布式的消息引擎系统 它的主要功能是提供一套完备的消息发布与订阅解决方案 在 Kafka 中，发布订阅的对象是主题（Topic），你可以为每个业务、每个应用甚至是每类数据都创建专属的主题 我们把生产者和消费者统称为客户端（Clients） 向主题发布消息的客户端应用程序称为生产者（P ...
分类：
其他好文 时间：
2020-04-27 13:38:33
阅读次数：
59
【目录】 一、 multiprocessing模块介绍 二、 process类的介绍 三、 process类的使用 四、僵尸进程和孤儿进程 五 、守护进程 六 、进程同步(互斥锁) 七 、队列--生产者消费者模型 一、 multiprocessing模块介绍 # python中的多线程无法利用多核优 ...
分类：
编程语言 时间：
2020-04-25 13:06:01
阅读次数：
97
阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。 这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当 队列满时，存储元素的线程会等待队列可用。 阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消 费者是从队列里拿元素的线程。阻塞队列就是生产 ...
分类：
其他好文 时间：
2020-04-25 01:11:11
阅读次数：
64
package main import ( "fmt" "strconv" "time" ) /* 改进生产者消费者模型 ·生产者每秒生产一件商品，并通知物流公司取货 ·物流公司将商品运输到商店 ·消费者阻塞等待从商店消费 ·消费10轮就主协程结束 ·尝试在整分钟时通知生产者罢工，生产者罢工时主协程 ...
分类：
编程语言 时间：
2020-04-24 19:58:50
阅读次数：
94
生产者分区原则 1.指定partition编号的情况下，直接将指明的值直接作为partition值 2.没有指明partition值但有key的情况下，将key的hash值与topic的partition数进行取余得到partition值 3.没有partition值也没有key值的情况下，第一次调 ...
分类：
其他好文 时间：
2020-04-24 01:22:31
阅读次数：
72
[Toc] 内容概要 进程对象及其他方法 僵尸进程与孤儿进程 守护进程 互斥锁 队列介绍 进程间通信IPC机制 生产者消费者模型 线程相关知识点 进程对象及其他方法 如何查看进程的PID号 命令法: windows: tasklist tasklist |findstr PID查看具体的进程 mac ...
分类：
编程语言 时间：
2020-04-23 23:19:00
阅读次数：
98
MQ全称为Message Queue,是一种应用程序对应用程序的通信方法，应用程序通过读写出入消息队列的数据来通信，从而无需专用连接来链接他们（如RPC）。 消息队列是典型的生产者和消费者模型，生产者和消费者只关心消息的发送和接受，没有业务逻辑的侵入，实现了生产者和消费者的解耦。 AMQP：一个提供 ...
分类：
其他好文 时间：
2020-04-23 22:56:09
阅读次数：
72
