为何采用 TCP？ Apache Kafka 的所有通信都是基于 TCP 的 而不是基于 HTTP 或其他协议 无论是生产者、消费者，还是 Broker 之间的通信都是如此 人们能够利用 TCP 本身提供的一些高级功能，比如多路复用请求以及同时轮询多个连接的能力 所谓的多路复用请求，即 multip ...
分类：
编程语言 时间：
2020-05-14 15:58:34
阅读次数：
102
例子： 生产者，消费者问题；消费者先进入临界区，条件变量未满足条件，阻塞等待；生产者无法进入临界区，从而无法修改条件变量，也就产生死锁； 解决方法：如果遇到条件变量未满足条件，消费者先释放锁，进入阻塞，等待条件变量得到满足；然后生产者可以进入临界区，修改条件变量，修改后通知消费者进入临界区，生产者释 ...
分类：
系统相关 时间：
2020-05-14 01:36:41
阅读次数：
76
一.wait/notity的使用 wait()方法可以使线程进入等待状态，而notify()可以使等待的状态唤醒。 这样的同步机制十分适合生产者、消费者模式：消费者消费某个资源，而生产者生产该资源。 当该资源缺失时，消费者调用wait()方法进行自我阻塞，等待生产者的生产；生产者生产完毕后调用not ...
分类：
其他好文 时间：
2020-05-12 14:08:20
阅读次数：
61
以下出现代码均为伪代码； 2.5.1 生产者 消费者问题（考试模型占比 60%） 分析上图：缓冲区存在互斥问题，生产者与消费者之间还 存在同步问题 1. 利用 记录型信号量 解决生产者 消费者问题(==背下来==) 假定在生产者和消费者之间的共用缓冲池中具有n个缓冲区，这时可以利用互斥信号量mute ...
分类：
系统相关 时间：
2020-05-11 00:57:40
阅读次数：
88
# 进城之间数据隔离 # 进程之间通信(IPC) Inter Process communication # 基于文件 :同一台机器上的多个进程之间通信 # Queue 队列 # 基于socket的文件级别的通信来完成数据传递的 # 基于网络 :同一台机器或者多台机器上的多进程间通信 # 第三方工具 ...
分类：
其他好文 时间：
2020-05-10 14:44:04
阅读次数：
65
队列：生产消费模式及线程池的运用 关注公众号 MageByte，设置星标获取最新干货。 “加群” 进入技术交流群获更多技术成长。 向固定大小的线程池投放请求任务时，若果线程池中没有空闲资源了，这时候还有新的请求进来，线程池如何处理这个请求？拒绝请求还是排队？使用怎样的处理机制 一般两种策略： 直接拒 ...
分类：
其他好文 时间：
2020-05-07 13:46:18
阅读次数：
61
·首先来看Put（）方法 final V putVal(K key, V value, boolean onlyIfAbsent) { if (key == null || value == null) throw new NullPointerException(); //寻找hash值，spre ...
分类：
编程语言 时间：
2020-05-04 17:08:12
阅读次数：
61
``` import java.util.LinkedList; /** * @Author 昊 * @Create 2020/5/2 9:34 * @Description 临界资源，存放汉堡 */ public class Box { //要进行频繁的删除操作所以使用LinkedList pri... ...
分类：
编程语言 时间：
2020-05-02 21:22:28
阅读次数：
77
回顾： 生产者消费者模型 主要为了解决强耦耦合的问题 队列 from multiprocessing import Queue 先进先出 队列本身是安全的 from multiprocessing import JoinableQueue task_done（） 每消费一个数据，就返回一个标识 jo ...
分类：
编程语言 时间：
2020-05-02 20:56:22
阅读次数：
66
有界缓冲问题有n个生产者和m个消费者，连接在一个有k个单位缓冲区的有界缓冲上。其中，pi和cj都是并发进程，只要缓冲区未满，生产者pi生产的产品就可投入缓冲区；只要缓冲区不空，消费者进程cj就可从缓冲区取走并消耗产品。 模型： int k; //k个单位的缓冲区 typedef anyitem it ...
分类：
其他好文 时间：
2020-04-29 23:24:49
阅读次数：
78
