SynchronousQueue 没有长度，每一个入队操作必须对应一个出队操作，或者每一个出队操作必须对应一个入栈操作，否则阻塞。SynchronousQueue内部提供两种模式TransferStack非公平模式（LIFO）和TransferQueue公平模式（FIFO）。 ...
分类：
编程语言 时间：
2020-04-23 23:22:51
阅读次数：
62
1 前言 与普通队列相比，阻塞队列另外支持两个附加操作，这两个附加的操作支持阻塞的插入和移除方法。 ①支持阻塞的插入方法：当队列满时，队列会阻塞插入元素的线程，直到队列不满。 ②支持阻塞的移除方法：在队列为空时，获取元素的线程会等待队列变为非空。 一般的阻塞队列相比，只能在“尾部入队、在头部出队”， ...
分类：
数据库 时间：
2020-04-22 13:17:35
阅读次数：
67
Java中常用的七个阻塞队列介绍第一篇 在上一篇我们对Java中的队列分类做了简单的介绍。本文咱们主要来聊聊阻塞队列中的七个常用子类。这七个阻塞队列的学习步骤：先看源码，分析完源码之后，我们再来对每个队列进行总结。最后在来个大总结。文章可能有点长，但是，大家耐着性子看完，保证你对这七大阻塞队列有深刻 ...
分类：
编程语言 时间：
2020-04-20 13:38:58
阅读次数：
61
在Python中如果想创建多进程需要用到multiprrocessing中的Prrocess方法。 在进程之间全局变量是不共享的，如果要对进程的全局变量进行使用的话就需要用到multiprrocessing的Queue方法 首先我们先创建一个多进程 import time from multipro ...
分类：
编程语言 时间：
2020-04-20 01:19:54
阅读次数：
78
1、一个线程占有一个对象的锁以后，CPU资源仍然能被其它线程抢走。 2、当其他线程抢走CPU资源后，发现获取不到对象锁，则此线程会进入阻塞状态，并且进入由于获取不到锁而阻塞的阻塞队列中。 3、当占有锁的线程释放对象锁的时候，就会立即唤醒等待对象锁的其他线程（都在阻塞队列中） 上面说的释放对象锁，包括 ...
分类：
其他好文 时间：
2020-04-17 23:45:35
阅读次数：
96
Java-五种线程池，四种拒绝策略，三种阻塞队列 三种阻塞队列： BlockingQueue<Runnable> workQueue = null; workQueue = new ArrayBlockingQueue<>(5);//基于数组的先进先出队列，有界 workQueue = new Li ...
分类：
编程语言 时间：
2020-04-16 19:32:41
阅读次数：
70
newFixedThreadPool @Slf4j public class TheadPoolDemo { private static ThreadPoolExecutor threadPool = (ThreadPoolExecutor) Executors.newFixedThreadPoo ...
分类：
编程语言 时间：
2020-04-15 00:30:38
阅读次数：
68
1 前言 队列是一种在尾部添加元素、从头部删除元素的数据结构，而阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作支持阻塞的插入和移除方法。 ①支持阻塞的插入方法：当队列满时，队列会阻塞插入元素的线程，直到队列不满。 ②支持阻塞的移除方法：在队列为空时，获取元素的线 ...
分类：
其他好文 时间：
2020-04-13 23:08:21
阅读次数：
74
一、前言 这几天准备研究一下 中阻塞队列的实现。 中的阻塞队列有七种，我准备逐一研究它们的源码，然后每一个阻塞队列写一篇分析博客，这是其中的第一篇。这篇博客就来说一说阻塞队列中我认为应该是最简单的一种—— 。 二、正文 2.1 什么是阻塞队列 在正式分析前，先简单介绍一下什么是阻塞队列。在说阻塞队列 ...
分类：
其他好文 时间：
2020-04-12 07:50:28
阅读次数：
70
RocketMQ为什么要保证订阅关系的一致性？ 搭建 RocketMQ 集群过程中遇到了关于消费订阅的问题，具体问题如下 报错的日志信息： the consumer's subscription not exist找到源码里报错的位置 org.apache.rocketmq.broker.proce ...
分类：
其他好文 时间：
2020-03-30 14:40:55
阅读次数：
92
