package bunny.queue;

import java.util.concurrent.ArrayBlockingQueue;

public class QueueArrayBlockingQueueTest1 {
    public static void main(String[] args) throws Exception {
        ArrayBlockingQueue<Integer> integers = new ArrayBlockingQueue<>(10);
        for (int i = 0; i < 20; i++) {
            boolean success = integers.offer(i);
            if (!success) {
                System.out.println("队列已满，无法插入元素：" + i);
            }
        }

        for (int i = 0; i < 10; i++) {
            integers.take();
        }

        System.out.println(integers);
    }
}