Java线程:堵塞队列与堵塞栈

简介: 一、堵塞队列   Java定义了堵塞队列的接口java.util.concurrent.BlockingQueue,堵塞队列是一个指定长度的队列,当试图向队列中添加元素而队列已满,或者是想从队列移出元素而队列为空的时候,堵塞队列导致线程堵塞。

一、堵塞队列

  Java定义了堵塞队列的接口java.util.concurrent.BlockingQueue,堵塞队列是一个指定长度的队列,当试图向队列中添加元素而队列已满,或者是想从队列移出元素而队列为空的时候,堵塞队列导致线程堵塞。

  在协调多个线程之间的合作时,堵塞队列是一个有用的工具。

  堵塞队列的方法分为三类,取决于当队列满或空时它们的相应方式。

    1、如果将队列当作线程管理工具使用,用到put()(添加一个元素)和take()(移出并返回头元素)方法。

    2、当试图向满的队列中添加或从从空的队列中移出元素时,用到add()、remove()(移出并返回头元素)、element()(返回队列的头元素)。

    3、在一个线程中,队列会在任何时候空或满时,用offer()(添加一个元素并返回true)、poll()(移出并返回队列的头元素)、peek()(返回队列的头元素)替代。这些方法如果不能完成任务,不会抛出异常,只会给出一个错误。

简单的例子:

  QueueTest.java

 1 package Thread;
 2 
 3 import java.util.concurrent.ArrayBlockingQueue;
 4 import java.util.concurrent.BlockingQueue;
 5 
 6 public class QueueTest {
 7     public static void main(String[] args)throws InterruptedException{
 8         BlockingQueue bqueue=new ArrayBlockingQueue(20);
 9         for (int i=0;i<30;i++){
10             bqueue.put(i);
11             System.out.println("向堵塞队列中添加了元素:"+i);
12         }
13         System.out.println("程序运行结束,即将退出---");
14     }
15 }
View Code

  结果为:

 1 向堵塞队列中添加了元素:0
 2 向堵塞队列中添加了元素:1
 3 向堵塞队列中添加了元素:2
 4 向堵塞队列中添加了元素:3
 5 向堵塞队列中添加了元素:4
 6 向堵塞队列中添加了元素:5
 7 向堵塞队列中添加了元素:6
 8 向堵塞队列中添加了元素:7
 9 向堵塞队列中添加了元素:8
10 向堵塞队列中添加了元素:9
11 向堵塞队列中添加了元素:10
12 向堵塞队列中添加了元素:11
13 向堵塞队列中添加了元素:12
14 向堵塞队列中添加了元素:13
15 向堵塞队列中添加了元素:14
16 向堵塞队列中添加了元素:15
17 向堵塞队列中添加了元素:16
18 向堵塞队列中添加了元素:17
19 向堵塞队列中添加了元素:18
20 向堵塞队列中添加了元素:19
View Code

二、栈

  对于堵塞栈,与堵塞队列相似,不同点是后入先出的结构,每次操作的都是栈顶,而队列是先进先出的结构,每次操作的对列头。堵塞栈定义了新街口java.util.concurrentBlockingDeque。例子:

  DequeTest.java

 1 package Thread;
 2 import java.util.concurrent.BlockingDeque;
 3 import java.util.concurrent.LinkedBlockingDeque;
 4 public class QueueTest {
 5     public static void main(String[] args)throws InterruptedException{
 6         BlockingDeque bqueue=new LinkedBlockingDeque(20);
 7         for (int i=0;i<30;i++){
 8             bqueue.put(i);
 9             System.out.println("向堵塞队列中添加了元素:"+i);
10         }
11         System.out.println("程序运行结束,即将退出---");
12     }
13 }
View Code

  结果为:

 1 向堵塞栈中添加了元素:0
 2 向堵塞栈中添加了元素:1
 3 向堵塞栈中添加了元素:2
 4 向堵塞栈中添加了元素:3
 5 向堵塞栈中添加了元素:4
 6 向堵塞栈中添加了元素:5
 7 向堵塞栈中添加了元素:6
 8 向堵塞栈中添加了元素:7
 9 向堵塞栈中添加了元素:8
10 向堵塞栈中添加了元素:9
11 向堵塞栈中添加了元素:10
12 向堵塞栈中添加了元素:11
13 向堵塞栈中添加了元素:12
14 向堵塞栈中添加了元素:13
15 向堵塞栈中添加了元素:14
16 向堵塞栈中添加了元素:15
17 向堵塞栈中添加了元素:16
18 向堵塞栈中添加了元素:17
19 向堵塞栈中添加了元素:18
20 向堵塞栈中添加了元素:19
View Code

 

当神已无能为力,那便是魔渡众生
目录
相关文章
|
13天前
|
监控 安全 Java
在 Java 中使用线程池监控以及动态调整线程池时需要注意什么?
【10月更文挑战第22天】在进行线程池的监控和动态调整时,要综合考虑多方面的因素,谨慎操作,以确保线程池能够高效、稳定地运行,满足业务的需求。
93 38
|
10天前
|
安全 Java
java 中 i++ 到底是否线程安全?
本文通过实例探讨了 `i++` 在多线程环境下的线程安全性问题。首先,使用 100 个线程分别执行 10000 次 `i++` 操作,发现最终结果小于预期的 1000000,证明 `i++` 是线程不安全的。接着,介绍了两种解决方法:使用 `synchronized` 关键字加锁和使用 `AtomicInteger` 类。其中,`AtomicInteger` 通过 `CAS` 操作实现了高效的线程安全。最后,通过分析字节码和源码,解释了 `i++` 为何线程不安全以及 `AtomicInteger` 如何保证线程安全。
java 中 i++ 到底是否线程安全?
|
1天前
|
安全 Java 测试技术
Java并行流陷阱:为什么指定线程池可能是个坏主意
本文探讨了Java并行流的使用陷阱,尤其是指定线程池的问题。文章分析了并行流的设计思想,指出了指定线程池的弊端,并提供了使用CompletableFuture等替代方案。同时,介绍了Parallel Collector库在处理阻塞任务时的优势和特点。
|
1天前
|
安全 Java 编译器
Java多线程编程的陷阱与最佳实践####
【10月更文挑战第29天】 本文深入探讨了Java多线程编程中的常见陷阱,如竞态条件、死锁、内存一致性错误等,并通过实例分析揭示了这些陷阱的成因。同时,文章也分享了一系列最佳实践,包括使用volatile关键字、原子类、线程安全集合以及并发框架(如java.util.concurrent包下的工具类),帮助开发者有效避免多线程编程中的问题,提升应用的稳定性和性能。 ####
15 1
|
4天前
|
存储 设计模式 分布式计算
Java中的多线程编程:并发与并行的深度解析####
在当今软件开发领域,多线程编程已成为提升应用性能、响应速度及资源利用率的关键手段之一。本文将深入探讨Java平台上的多线程机制,从基础概念到高级应用,全面解析并发与并行编程的核心理念、实现方式及其在实际项目中的应用策略。不同于常规摘要的简洁概述,本文旨在通过详尽的技术剖析,为读者构建一个系统化的多线程知识框架,辅以生动实例,让抽象概念具体化,复杂问题简单化。 ####
|
5天前
|
Java 开发者
在Java多线程编程的世界里,Lock接口正逐渐成为高手们的首选,取代了传统的synchronized关键字
在Java多线程编程的世界里,Lock接口正逐渐成为高手们的首选,取代了传统的synchronized关键字
30 4
|
8天前
|
缓存 安全 C++
C++无锁队列:解锁多线程编程新境界
【10月更文挑战第27天】
24 7
|
5天前
|
消息中间件 供应链 Java
掌握Java多线程编程的艺术
【10月更文挑战第29天】 在当今软件开发领域,多线程编程已成为提升应用性能和响应速度的关键手段之一。本文旨在深入探讨Java多线程编程的核心技术、常见问题以及最佳实践,通过实际案例分析,帮助读者理解并掌握如何在Java应用中高效地使用多线程。不同于常规的技术总结,本文将结合作者多年的实践经验,以故事化的方式讲述多线程编程的魅力与挑战,旨在为读者提供一种全新的学习视角。
26 3
|
12天前
|
安全 Java
在 Java 中使用实现 Runnable 接口的方式创建线程
【10月更文挑战第22天】通过以上内容的介绍,相信你已经对在 Java 中如何使用实现 Runnable 接口的方式创建线程有了更深入的了解。在实际应用中,需要根据具体的需求和场景,合理选择线程创建方式,并注意线程安全、同步、通信等相关问题,以确保程序的正确性和稳定性。
|
8天前
|
消息中间件 存储 安全