Kotlin-Demo/bunny/queue/QueueArrayBlockingQueueTest...

22 lines
600 B
Java
Raw Permalink Normal View History

2024-08-20 13:52:40 +08:00
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);
}
}