这里定义了一个有界队列 ,保证先进先出,在队列达到上限时应该阻塞,直到队列有元素被取出才能继续往里继续添加
完整代码:
package com.comic.queue;import java.util.LinkedList;import java.util.concurrent.atomic.AtomicInteger;public class BoundedQueue { // 队列的最大值 private int maxSize; // 计数器 private AtomicInteger counter = new AtomicInteger(0); // 数据容器 private LinkedList 控制台部分:
aa入列bb入列cc入列dd入列ff入列队列已满,请等待....**********************************take:aagg入列队列已满,请等待....take:bbhh入列
