Java 数组阻塞队列 ArrayBlockingQueue

本文主要是介绍Java 数组阻塞队列 ArrayBlockingQueue，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

参考

• 狂神说

描述

由数组支持的有界blocking queue 。 此队列命令元素FIFO（先进先出）。 队列的头部是队列中最长时间的元素。 队列的尾部是队列中最短时间的元素。 在队列的尾部插入新元素，队列检索操作获取队列头部的元素。

有些方法是继承的，所以一些方法在这个类 ArrayBlockingQueue 上面看不到。另外 add() 调用的 offer()，但是 offer() 不会报错，返回 null；remove() 调用的还是 poll()，但是 poll() 不会报错，返回 null。

代码

1. add/remove 如果满了/如果为空则抛出异常

package thread;

import java.util.concurrent.*;
/**
 * @Author 夏秋初
 * @Date 2022/3/2 19:00
 */
public class Test {
    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue(5);
        for (int i = 0; i < 5; i++) {
            System.out.println(arrayBlockingQueue.add(String.valueOf(i)));
        }
        for (int i = 0; i < 5; i++) {
            System.out.println(arrayBlockingQueue.remove());
        }
    }
}

2. offer/poll 如果满了/如果为空则返回null

package thread;

import java.util.concurrent.*;
/**
 * @Author 夏秋初
 * @Date 2022/3/2 19:00
 */
public class Test {
    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue(5);
        for (int i = 0; i < 5; i++) {
            System.out.println(arrayBlockingQueue.offer(String.valueOf(i)));
        }
        for (int i = 0; i < 5; i++) {
            System.out.println(arrayBlockingQueue.poll());
        }
    }
}

3. put/take 如果满了/如果为空则等待元素的插入/取出

package thread;

import java.util.concurrent.*;
/**
 * @Author 夏秋初
 * @Date 2022/3/2 19:00
 */
public class Test {
    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue(5);
        for (int i = 0; i < 5; i++) {
            arrayBlockingQueue.put(String.valueOf(i));
        }
        for (int i = 0; i < 5; i++) {
            System.out.println(arrayBlockingQueue.take());
        }
    }
}

4. offer/poll 如果满了/如果为空则根据指定时间等待元素的插入/取出，超出结束

package thread;

import java.util.concurrent.*;
/**
 * @Author 夏秋初
 * @Date 2022/3/2 19:00
 */
public class Test {
    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue(5);
//        for (int i = 0; i < 5; i++) {
//            arrayBlockingQueue.offer(String.valueOf(i), 5, TimeUnit.SECONDS);
//        }
        for (int i = 0; i < 5; i++) {
            System.out.println(arrayBlockingQueue.poll(5, TimeUnit.SECONDS));
        }
    }
}

5. element/peek 判断队列头是否有元素，有就返回/抛出异常

package thread;

import java.util.concurrent.*;
/**
 * @Author 夏秋初
 * @Date 2022/3/2 19:00
 */
public class Test {
    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue(5);
        for (int i = 0; i < 5; i++) {
            arrayBlockingQueue.offer(String.valueOf(i), 5, TimeUnit.SECONDS);
        }
//        for (int i = 0; i < 5; i++) {
//            System.out.println(arrayBlockingQueue.poll(5, TimeUnit.SECONDS));
//        }
        System.out.println(arrayBlockingQueue.element());
        System.out.println(arrayBlockingQueue.peek());
    }
}

这篇关于Java 数组阻塞队列 ArrayBlockingQueue的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！