技术文章 > java >  java基础 > 正文

java中ArrayBlockingQueue的使用

小妮浅浅

在阻塞队列中,有一种需要结合数组使用的阻塞队列,那就是ArrayBlockingQueue。在其并发控制上,插入和读写的功能又与锁的使用密切相关。先看我们就java中ArrayBlockingQueue的概念、特点进行介绍,然后带领大家在实例中体会ArrayBlockingQueue的使用方法。

1.概念

java并发包下一个以数组实现的阻塞队列, 是 BlockingQueue 接口的有界队列实现类,底层采用数组来实现。

2.特点

初始化一定容量的数组;

使用一个重入锁,默认使用非公平锁,入队和出队共用一个锁,互斥;

是有界设计,如果容量满无法继续添加元素直至有元素被移除;

使用时开辟一段连续的内存,如果初始化容量过大容易造成资源浪费,过小易添加失败。

3.实例

package TestBlockingQueue;
 
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
 
public class ThreadPoolTest implements Runnable {
 
    @Override
    public void run() {
        synchronized (this) {
            System.out.println(Thread.currentThread().getName());
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
 
    public static void main(String[] args) {
        // BlockingQueue<Runnable> queue = new LinkedBlockingDeque<Runnable>();
        BlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(5);
        ThreadPoolExecutor executor = new ThreadPoolExecutor(3, 6, 1,
                TimeUnit.DAYS, queue);
        for (int i = 0; i < 12; i++) {
            executor.execute(new Thread(new ThreadPoolTest(), "TestThread"
                    .concat("" + i)));
            int threadSize = queue.size();
            System.out.println("线程队列大小为-->" + threadSize);
        }
        executor.shutdown();
    }
}

运行结果

以上就是java中ArrayBlockingQueue的使用,需要我们先掌握数组和锁的基本概念,然后才能结合在一起使用。对这些基本知识掌握不够牢固的,可以在课后进行复习回顾。

免费视频教程
本文原创发布python学习网,转载请注明出处,感谢您的尊重!
相关文章
 java线程池的运行流程
 java线程池创建方式
 java线程池异常的处理方法
 java线程池的工作队列有哪几个
 BlockingQueue在java中的使用
相关视频章节
 网络爬虫
 云端部署Web应用程序视频
 Web应用框架Flask和文件模板
 Web应用程序开发概述
 继承和多态
推荐视频
视频教程分类