Concurrent包是jdk5中开始提供的一套并发编程包,其中包含了大量和多线程开发相关的工具类,大大的简化了java的多线程开发,在高并发 分布式场景下应用广泛。本文主要介绍BlockingQueue阻塞队列。
概述
java.util.concurrent 包里的 BlockingQueue 接口表示一个线程安放入和提取实例的队列。
2024年04月21日
Concurrent包是jdk5中开始提供的一套并发编程包,其中包含了大量和多线程开发相关的工具类,大大的简化了java的多线程开发,在高并发 分布式场景下应用广泛。本文主要介绍BlockingQueue阻塞队列。
java.util.concurrent 包里的 BlockingQueue 接口表示一个线程安放入和提取实例的队列。
2024年04月21日
并发编程在互联网技术使用如此广泛，几乎所有的后端技术面试官都要在并发编程的使用和原理方面对小伙伴们进行 360° 的刁难。
2024年04月21日
在Java并发编程领域，共享资源的有效管理至关重要。线程安全的数据结构在确保线程之间的协调与同步方面发挥着关键作用。其中，LinkedBlockingQueue和ConcurrentLinkedQueue作为在并发环境中管理队列的通用实现尤为重要。在本文中，我们将更深入地了解这两个队列实现的复杂性，分析它们的底层机制、性能特征以及最佳应用场景。
2024年04月21日
我在前段时间写了一篇关于AQS源码解析的文章AbstractQueuedSynchronizer超详细原理解析 [链接见文末]，在文章里边我说JUC包中的大部分多线程相关的类都和AQS相关，今天我们就学习一下依赖于AQS来实现的阻塞队列BlockingQueue的实现原理。本文中的源码未加说明即来自于以ArrayBlockingQueue。
2024年04月21日
阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。阻塞队列就是生产者存放元素的容器，而消费者也只从容器里拿元素。
2024年04月21日
最近出了个故障，排查的时候耗费了很长的时间，回顾整个排查过程，经验主义在这里起了不好的作用，直接导致了整个故障排查的时间非常长，这个故障的根本原因在于BlockingQueue用的有问题，顺带展开说说Java中常用的几个BlockingQueue：ArrayBlockingQueue、LinkedBlockingQueue和SynchronousQueue。
2024年04月21日
在前面的三篇文章中，我们一起陆续地研究了AQS的底层原理，同时研究了AQS在不同场景下的三个应用工具类（ReentrantLock、CountDownLatch、Semaphore）的工作原理，之所以和大家一起分析它们，是因为这三个类是我们平时工作中应用最多的类了，其实
2024年04月21日
如下阻塞队列+线程的代码，很常见，当服务停止时，如何停止被BlockingQueue阻塞的线程？
BlockingQueue<Integer> blockingQueue = new ArrayBlockingQueue(10);
final Thread thread = new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
Integer el = blockingQueue.take();
System.out.println(el);
} catch (InterruptedException e) {
}
}
}
});