Java 8 - juc - ConcurrentLinkedQueue

野性酷女 2023-10-11 22:42 33阅读 0赞

import java.util.concurrent.ConcurrentLinkedQueue;
    
    /**
     * ConcurrentLinkedQueue
     *
     * 使用offer()方法向队列中添加元素。
     * 使用size()方法获取队列的大小。
     * 使用增强的for循环遍历队列元素。
     * 使用contains()方法检查队列是否包含某个元素。
     * 使用poll()方法移除队列头部的元素。
     * 使用peek()方法获取队列头部的元素但不移除。
     * 使用clear()方法清空队列中的所有元素。
     * 使用isEmpty()方法检查队列是否为空。
     */
    public class MyConcurrentLinkedQueueExample {
        
        public static void main(String[] args) {
        
            // 创建并发链表队列
            ConcurrentLinkedQueue<String> queue = new ConcurrentLinkedQueue<>();
    
            // 添加元素到队列
            queue.offer("Apple");
            queue.offer("Banana");
            queue.offer("Orange");
    
            // 获取队列大小
            int size = queue.size();
            System.out.println("队列大小: " + size);
    
            // 遍历队列元素
            System.out.println("队列元素:");
            for (String element : queue) {
        
                System.out.println(element);
            }
    
            // 检查队列是否包含某个元素
            boolean contains = queue.contains("Banana");
            System.out.println("队列是否包含元素 'Banana': " + contains);
    
            // 移除队列头部元素
            String head = queue.poll();
            System.out.println("移除的队列头部元素: " + head);
    
            // 获取队列头部元素但不移除
            String peek = queue.peek();
            System.out.println("队列头部元素: " + peek);
    
            // 清空队列
            queue.clear();
    
            // 检查队列是否为空
            boolean isEmpty = queue.isEmpty();
            System.out.println("队列是否为空: " + isEmpty);
        }
    }