标签：Java String 队列 ++ int arrayBlockingQueue ArrayBlockingQueue public

参考

• 狂神说

描述

由数组支持的有界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,String,队列,++,int,arrayBlockingQueue,ArrayBlockingQueue,public
来源： https://www.cnblogs.com/xiaqiuchu/p/15956694.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。