Java队列和栈的阻塞机制是如何实现的？

本文共计1150个文字，预计阅读时间需要5分钟。

实现消息通讯，消息不断从网络流中获取，后台线程持续消费。以往我主要通过一些线程安全标识或方法来控制，后来在网上发现一些Java新特性，其中包含可用的栈堆操作。

做消息通信，消息会不断从网络流中取得，而后台也有线程不断消费。本来我一直是使用一些线程安全标识或方法来控制，后来在网上找到一些java新特性，里面包含了可以用到的堆栈使用，而且是堵塞的，这样至少可以保证一些安全性。

对于堆：

BlockingQueue 不接受 null 元素。试图 add、put 或 offer 一个 null 元素时，某些实现会抛出 NullPointerException。null 被用作指示 poll 操作失败的警戒值。

BlockingQueue 可以是限定容量的。它在任意给定时间都可以有一个 remainingCapacity，超出此容量，便无法无阻塞地 put 附加元素。没有任何内部容量约束的 BlockingQueue 总是报告 Integer.MAX_VALUE 的剩余容量。

BlockingQueue 实现主要用于生产者-使用者队列，但它另外还支持 Collection接口。因此，举例来说，使用 remove(x) 从队列中移除任意一个元素是有可能的。然而，这种操作通常不 会有效执行，只能有计划地偶尔使用，比如在取消排队信息时。

BlockingQueue 实现是线程安全的。