工作队列比简单队列在消费者这边多了一个方法。 channel.basicQos(1);公平队列消费(参数设置为1，表示消费者消费完一条才会去接受再次发来的消息) 生产者： 消费者1： 消费者2： ...
分类：
其他好文 时间：
2019-04-06 09:17:43
阅读次数：
107
程序清单 5-8 桌面搜索应用程序中的生产者任务和消费者任务（和书上有所不同，有些许改动） 1、生产者 2、消费者 3调用 ...
分类：
其他好文 时间：
2019-04-05 14:21:17
阅读次数：
113
前言 生产者和消费者问题是多线程模型中的经典问题：生产者和消费者在同一时间段内共用同一个存储空间，生产者往存储空间中添加产品，消费者从存储空间中取走产品，当存储空间为空时，消费者阻塞，当存储空间满时，生产者阻塞。 在JAVA中实现生产者消费者问题时，有三种常用的方式： 使用Object的wait/n ...
分类：
编程语言 时间：
2019-04-03 00:01:26
阅读次数：
218
原理 生产者在仓库没有满的时候进行生产，满了后等待 消费者在仓库有存货事新型消费，没货是等待 示例 #Phone #Storage 说明： synchonized保证对象只能被一个线程占用 执行wat()后，当前线程处于等待状态，释放锁，让别的线程可以继续执行 执行notify()后，唤醒其他处于w ...
分类：
其他好文 时间：
2019-03-31 13:30:34
阅读次数：
162
什么是线程？ 程序的执行线路。每个进程默认有一条线程。线程包含了程序的具体步骤。 多线程就是一个进程中有除主线程（默认线程）外还有多个线程。 线程与进程的关系（进程包含线程，而线程依赖进程存在） 1.进程包含了运行该程序的所有资源，是一个资源单位。 2.线程是CPU的执行单位（最小的执行单位）。 3 ...
分类：
编程语言 时间：
2019-03-26 01:22:52
阅读次数：
176
最近在学线程,在加上操作系统也在学线程,于是乎有了这篇文章 问题描述: 一群生产者进程在生成产品,并将这些产品提供给消费者进程去消费. 他们之间有一个公共的缓冲区用来存放产品,当产品为空时消费者不能消费,当产品为满时生产者不能生产 CPP实现 利用mutex 互斥量 来对缓存区的操作进行加锁 C++ ...
分类：
系统相关 时间：
2019-03-19 01:02:36
阅读次数：
197
1 线程同步 1.1 线程安全 java允许多线程并发控制，当多个线程同时操作一个可共享资源变量时（如对其进行增删改查操作），会导致数据不准确，而且相互之间产生冲突。所以加入同步锁以避免该线程在没有操作完共享资源前其他线程操作共享资源，从而保证该变量的唯一性和准确性。 不同步会发生什么问题？在介绍同 ...
分类：
编程语言 时间：
2019-03-18 11:46:34
阅读次数：
172
1.大纲 Kafka控制节点用的是什么？ 消费者、生产者是如何理解的？ 2.Kafka控制节点用的是什么？ 基于zookeeper协调的分布式消息系统 3.消费者、生产者是如何理解的？ 消息系统通常都会由生产者，消费者，Broker三大部分组成，生产者会将消息写入到Broker，消费者会从Broke ...
分类：
其他好文 时间：
2019-03-14 00:43:16
阅读次数：
188
背景 进程间的交互关系 临界区（critical section）的访问过程 需要满足原则: 如何实现进程间的互斥 轮流 申请 算法一： 算法二： 算法三 信号量 实现进程间互斥 用进程实现同步： 哲学家问题 信号量 经典问题 哲学家问题 解决办法: 解决办法: 生产者-消费者问题 读者-写者问题 ...
分类：
系统相关 时间：
2019-03-03 19:03:41
阅读次数：
215
队列是常用的数据结构，采用的FIFO(first in firstout)原则，新元素（等待进入队列的元素）总是被插入到尾部，而读取的时候总是从头部开始读取。在计算中队列一般用来做排队(如线程池的等待排队，锁的等待排队)，用来做解耦（生产者消费者模式），异步等等。在java多线程应用中，队列的使用率 ...
分类：
其他好文 时间：
2019-03-01 18:46:11
阅读次数：
238
