• 技术文章 >java >java基础

    java中ArrayBlockingQueue的使用

    小妮浅浅小妮浅浅2021-01-11 13:46:45原创3494

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

    1.概念

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

    2.特点

    初始化一定容量的数组;

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

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

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

    3.实例

    1

    2

    3

    4

    5

    6

    7

    8

    9

    10

    11

    12

    13

    14

    15

    16

    17

    18

    19

    20

    21

    22

    23

    24

    25

    26

    27

    28

    29

    30

    31

    32

    33

    34

    35

    36

    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的使用,需要我们先掌握数组和锁的基本概念,然后才能结合在一起使用。对这些基本知识掌握不够牢固的,可以在课后进行复习回顾。

    专题推荐:java arrayblockingqueue
    上一篇:BlockingQueue在java中的使用 下一篇:java ArrayBlockingQueue源码探讨

    相关文章推荐

    • java线程池的运行流程• java线程池创建方式• java线程池异常的处理方法• java线程池的工作队列有哪几个• BlockingQueue在java中的使用

    全部评论我要评论

    © 2021 Python学习网 苏ICP备2021003149号-1

  • 取消发布评论
  • 

    Python学习网