ArrayBlockQueue函数及应用场景是什么

今天小编给大家分享一下ArrayBlockQueue函数及应用场景是什么的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。队列在生活中随处可见，医院缴费需要排队、做核酸需要排队、汽车等红绿灯需要排队等等。队列是一个按照先来到就排在前面，后来到排在后面的数据结构，并且出队的时候也是按照先来到先出队。使用数组和链表进行实现。通常用于协调任务的执行和数据的交换。ArrayBlockingQueue 是一个有界阻塞队列，有界指的是队列存在一个最大容量；阻塞指的是如果队列已经满了，想要往队列继续添加元素的话，那么这个操作将会被暂停，直到队列中有空位才会继续完成添加操作。如果队列已经为空，想要从队列中获取元素，那么这个操作将会被暂停，直接队列中存在元素才会继续完成获取操作。它具有线程安全、性能好、公平锁选项的特点：线程安全：使用锁和条件变量实现线程安全，无需额外的同步措施。阻塞操作：当队列满时，插入操作阻塞；当队列空时，删除操作阻塞。这有助于避免忙等待和减少无意义的资源消耗。公平锁选项：支持是否使用公平锁。避免锁饥饿。高性能：基于数组实现，内存连续分配，访问性能较高。但是同时也存在不灵活、无法支撑高并发的缺点有界性：队列的容量固定，不可动态改变。因此在创建时分配多大容量将成为关键，分配过多会造成资源浪费，分配过少会造成竞争激烈。锁竞争：在高并发情况下，锁竞争可能会导致性能下降。ArrayBlockingQueue 内部使用数组作为元素的存储结构。执行存取操作时，都必须先获取锁，才可以执行存取操作，这就保证ArrayBlockingQueue 是线程安全。ArrayBlockingQueue 通过两个 Condition 条件队列，一个 notFull 条件，一个 notEmpty 条件。在对队列进行插入元素操作时，判断当前队列已经满，则通过 notFull 条件将线程阻塞，直到其他线程通知该线程队列可以继续插入元素。在对队列进行移除元素操作时，判断当前队列已经空，则通过 notEmpty 条件阻塞线程，直到其他线程通过该线程可以继续获取元素。这样保证线程的存取操作不会出现错误。避免队列在满时，丢弃插入的元素；也避免在队列空时取到一个 null 值。构造函数中，需要指定队列的容量和是否使用公平锁。并且创建了两个 Condition 条件队列，分别命名为 notEmpty 和 notFull，这两个条件队列是实现阻塞的关键。通过构造函数我们可以知道为什么它叫有界：因为创建数组时，需要指定数组的容量，并且数组容量不能在运行中动态扩大。所以队列的容量是有边界的，不是无限扩张的。获取锁判断当前队列是否已经满了如果队列1已经满了，调用 notFull 条件队列的 await() 方法，将该线程阻塞，暂停该线程的插入操作。避免内部溢出的问题。如果没免费云主机域名有满，则直接调用入队函数 enqueue 插入到队列末尾。解锁获取锁判断当前队列是否为空如果队列没有元素，调用 notEmpty 条件队列的 await() 方法，将该线程阻塞，暂停该线程的获取操作。避免获取元素出错。如果不为空，则直接调用出队函数 dequeue 移除队列第一个元素，并返回给客户端。释放锁将元素插入到队列的尾部，在完成插入操作之后会调用 notEmpty 对象的 signal 方法，告诉 notEmpty 阻塞队列，现在队列中已经有元素，之前因为队列没有元素而被阻塞的线程，现在可以来获取元素了。内部维护一个 putIndex，用于表示下一个将要插入元素的坐标。当 putIndex 等于数组长度时，将会重置为 0。putIndex 是一个从 0 – length 循环使用的坐标。维护一个 count 变量，用于表示队列中存在多少元素，在存入的时候增加，在取出的时候减少。将队列的第一个元素移除，并返回给客户端。在完成移除操作之后会调用 notFull 对象的 signal 方法，告诉 notFull 阻塞队列，现在队列中已经有空位了，之前因为队列没有空位而被阻塞的线程，现在可以继续插入元素。内部维护一个 takeIndex，用于表示下一个可以获取元素的坐标。当 takeIndex 等于数组长度时，将会重置为 0。takeIndex 是一个从 0 至数组长度之间循环使用的坐标。ArrayBlockingQueue 适用于多个线程之间需要共享数据、协调任务执行的场景。因此可以总结出以下几个应用场景：线程池：线程池是一个常见的并发编程模型，它通过线程池中的线程执行任务。并且可以重复使用这些线程。在线程池中，可以使用 ArrayBlockingQueue 来存储需要执行的任务，以此控制任务数量和执行顺序。当线程池中的线程执行完任务之后，可以从 ArrayBlockingQueue 中取出下一个任务执行。生产者-消费者：在生产者-消费者模型中，生产者负责生产数据，消费者负责对数据进行处理。在这种模式下，ArrayBlockingQueue 可以作为生产者与消费者之间的数据通道，保证线程安全和数据正确。Apache Tomcat Apache Tomcat 是一个流行的 Java Web 应用服务器，它使用 ArrayBlockingQueue 来实现内部的请求队列。当请求到达 Tomcat 时，它们被放入一个 ArrayBlockingQueue 中，并由工作线程从队列中取出并处理请求。Netty Netty 是一个高性能的网络编程框架，它使用 ArrayBlockingQueue 来实现内部的事件队列。当有新的网络事件到达时，它们被放入一个 ArrayBlockingQueue 中，并由 IO 线程从队列中取出并处理事件。以上就是“ArrayBlockQueue函数及应用场景是什么”这篇文章的所有内容，感谢各位的阅读！相信大家阅读完这篇文章都有很大的收获，小编每天都会为大家更新不同的知识，如果还想学习更多的知识，请关注百云主机行业资讯频道。

相关推荐: python整数的进制怎么转换

本文小编为大家详细介绍“python整数的进制怎么转换”，内容详细，步骤清晰，细节处理妥当，希望这篇“python整数的进制怎么转换”文章能帮助大家解决疑免费云主机域名惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。1、oct函数将十进制数转换为八进制数，…