Java中的ConcurrentLinkedQueue poll（）方法-yiteyi-C++库

这个投票方法 ConcurrentLinkedQueue 用于删除并返回此ConcurrentLinkedQueue的头。如果ConcurrentLinkedQueue为空，则此方法将返回null。

null

语法：

public E poll()

返回： 此方法删除并返回头此ConcurrentLinkedQueue或 无效的 如果此队列为空。

下面的程序演示了ConcurrentLinkedQueue的poll（）方法：

例1：

                     // Java Program Demonstrate poll()                   
                     // method of ConcurrentLinkedQueue                   
                             
                     import                               java.util.concurrent.*;                   
                             
                     public                               class                               GFG {                   
                                         public                               static                               void                               main(String[] args)                   
                                         {                   
                             
                                         // create an ConcurrentLinkedQueue                   
                                         ConcurrentLinkedQueue<Integer>                   
                                         queue =                               new                               ConcurrentLinkedQueue<Integer>();                   
                             
                                         // Add Numbers to queue                   
                                         queue.add(                               4353                               );                   
                                         queue.add(                               7824                               );                   
                                         queue.add(                               78249                               );                   
                                         queue.add(                               8724                               );                   
                             
                                         // Displaying the existing ConcurrentLinkedQueue                   
                                         System.out.println(                               "ConcurrentLinkedQueue: "                               + queue);                   
                             
                                         // apply poll()                   
                                         int                               response1 = queue.poll();                   
                             
                                         // print after applying poll method                   
                                         System.out.println(                               "Head: "                               + response1);                   
                             
                                         // Displaying the existing ConcurrentLinkedQueue                   
                                         System.out.println(                               "Current ConcurrentLinkedQueue: "                               + queue);                   
                                         }                   
                     }                   

输出：

ConcurrentLinkedQueue: [4353, 7824, 78249, 8724]
Head: 4353
Current ConcurrentLinkedQueue: [7824, 78249, 8724]

例2：

                     // Java Program Demonstrate poll()                   
                     // method of ConcurrentLinkedQueue                   
                             
                     import                               java.util.concurrent.*;                   
                             
                     public                               class                               GFG {                   
                                         public                               static                               void                               main(String[] args)                   
                                         {                   
                             
                                         // create an ConcurrentLinkedQueue                   
                                         ConcurrentLinkedQueue<String>                   
                                         queue =                               new                               ConcurrentLinkedQueue<String>();                   
                             
                                         // Add String to queue                   
                                         queue.add(                               "Aman"                               );                   
                                         queue.add(                               "Amar"                               );                   
                                         queue.add(                               "Sanjeet"                               );                   
                                         queue.add(                               "Rabi"                               );                   
                             
                                         // Displaying the existing ConcurrentLinkedQueue                   
                                         System.out.println(                               "ConcurrentLinkedQueue: "                               + queue);                   
                             
                                         // apply poll() on queue                   
                                         String response1 = queue.poll();                   
                             
                                         // print after applying poll method                   
                                         System.out.println(                               "Head: "                               + response1);                   
                             
                                         // Displaying the existing ConcurrentLinkedQueue                   
                                         System.out.println(                               "Current ConcurrentLinkedQueue: "                               + queue);                   
                             
                                         // apply poll() on queue more than one time                   
                                         queue.poll();                   
                                         queue.poll();                   
                             
                                         // Displaying the existing ConcurrentLinkedQueue                   
                                         System.out.println(                               "After 2 poll() applied"                   
                                         +                               "ConcurrentLinkedQueue: "                               + queue);                   
                                         }                   
                     }                   

输出：

ConcurrentLinkedQueue: [Aman, Amar, Sanjeet, Rabi]
Head: Aman
Current ConcurrentLinkedQueue: [Amar, Sanjeet, Rabi]
After 2 poll() applied
ConcurrentLinkedQueue: [Rabi]

参考： https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html#poll–

文章版权归作者所有，未经允许请勿转载。

THE END

Java