Java ConcurrentLinkedQueue 类

2024 年 10 月 21 日 | 阅读 3 分钟

ConcurrentLinkedQueue 是一个无界线程安全的队列，它按 FIFO 顺序排列元素。新元素添加到此队列的尾部，元素从队列的头部添加。

ConcurrentLinkedQueue 类及其迭代器实现了 Queue 和 Iterator 接口的所有可选方法。

方法

方法	描述
add()	将指定的元素插入此队列的尾部
addAll()	将指定集合中存在的所有元素插入此队列的尾部
contains()	如果此队列包含指定的元素，则返回 true
forEach()	对每个元素执行给定的操作，直到处理完所有元素。
isEmpty()	如果此队列不包含任何元素，则返回 true。
iterator()	返回此队列中元素的迭代器
offer()	将指定的元素插入此队列的尾部
remove()	如果此队列中存在指定的元素，则从此队列中删除该元素
removeAll()	从此队列中删除指定集合中存在的所有元素。
removeIf()	删除此队列中满足给定谓词筛选器的所有元素。
retainAll()	仅保留此队列中存在于指定集合中的那些元素。
size()	返回此队列中元素的数量。
spliterator()	返回此队列中元素的分割器。
toArray()	返回一个包含此队列所有元素的数组，这些元素按正确的顺序排列。

示例 1

import java.util.concurrent.ConcurrentLinkedQueue;
public class JavaConcurrentLinkedQueueExample1 {
    public static void main(String[] args) {
        int j =1;
        ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<Integer>();
        for (int i = 1; i <=5; i++) {
            //  Adding items to the tail of this queue
            queue.add(i);}
            //inserts the element at the tail of this queue
            queue.offer(6);
            System.out.println("Queue : "+queue);
            //Returns true if this queue contains the specified element
            if(queue.contains(4)){
                System.out.println("This queue conatins 4");
            }
            else{
                System.out.println("4 is absent");
            }
        //returns true if the queue is empty
        if(queue.isEmpty()){
            System.out.println("Add some elements because the queue is empty.");
        }
        else{
            System.out.println("Queue is not empty");
        }
    }
}

立即测试

输出

Queue : [1, 2, 3, 4, 5, 6]
This queue conatins 4
Queue is not empty

示例 2

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ConcurrentLinkedQueue;
public class JavaConcurrentLinkedQueueExample2 {
    public static void main(String[] args) {
       ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<Integer>();
       List<Integer> list = new ArrayList<Integer>();
       queue.add(11);
       queue.add(100);
       queue.add(122);
       queue.add(102);
       queue.add(112);
       list.add(11);
       list.add(100);
       System.out.println("Elements in queue : "+queue);
       //remove() method will remove the specified element from the queue
       queue.remove(122);
       queue.remove(102);
       System.out.println("Remaining elements in queue : "+queue);
       //Removes all the elements of this in queue which are present in the list
       queue.removeAll(list);
       System.out.println("Elemts of the list will get removed : "+queue);
       //Retain only those elements in this queue that are present in the list
       queue.retainAll(list);
       System.out.println("Queue will retain the elements of the list: "+queue);
      }
}

立即测试

输出

Elements in queue : [11, 100, 122, 102, 112]
Remaining elements in queue : [11, 100, 112]
Elemts of the list will get removed : [112]
Queue will retain the elements of the list: []

下一个主题Java ConcurrentLinkedQueue

Java ConcurrentLinkedQueue 类

方法

示例 1

示例 2

联系信息

关注我们

教程

面试题

在线编译器

Python

Java

.Net Framework

AI, ML and Data Science

Cloud Technology

B.Tech and MCA

Web Technology

PHP

Software Testing

Technical Interview

Java Interview

Python

Web Interview

Database Interview

B.Tech / MCA

Important Interview

Software Testing Interview

Company Interviews

Online Compilers

Multiple Choice Questions

Java ConcurrentHashMap

Java ConcurrentLinkedQueue

Java ConcurrentLinkedQueue 类

方法

示例 1

示例 2

相关帖子

Java ConcurrentLinkedQueue forEach() 方法

Java ConcurrentLinkedQueue retainAll() 方法

Java ConcurrentLinkedQueue iterator() 方法

Java ConcurrentLinkedQueue remove() 方法

Java ConcurrentLinkedQueue offer() 方法

Java ConcurrentLinkedQueue contains() 方法

Java ConcurrentLinkedQueue spliterator() 方法

Java ConcurrentLinkedQueue size() 方法

Java ConcurrentLinkedQueue add() 方法

Java ConcurrentLinkedQueue toArray() 方法

订阅 Tpoint Tech

联系信息

关注我们

教程

面试题

在线编译器