Java中的PriorityBlockingQueue poll（）方法

3611

1.poll（）方法

这个 投票 方法 优先阻塞队列 从头部检索并删除元素 优先封锁队列。该方法返回它从PriorityBlockingQueue中移除的元素，但当队列为空时，该方法将返回null。

null

语法： 

public E poll()

返回： 此方法返回 要素 来自此PriorityBlockingQueue的头，如果此队列为空，则为null。

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

例1： 程序演示PriorityBlockingQueue上的poll（）方法，以从数字列表中删除元素。

// Java Program Demonstrate poll()
// method of PriorityBlockingQueue
import java.util.concurrent.PriorityBlockingQueue;
public class GFG {
public static void main(String[] args)
{
// define capacity of PriorityBlockingQueue
int capacityOfQueue = 5 ;
// create object of PriorityBlockingQueue
PriorityBlockingQueue<Integer> PrioQueue
= new PriorityBlockingQueue<Integer>(capacityOfQueue);
// Add numbers to PriorityBlockingQueue
PrioQueue.offer( 35658786 );
PrioQueue.offer( 5278367 );
PrioQueue.offer( 74381793 );
PrioQueue.offer( 87625142 );
// remove numbers from head using poll()
// and print removed number
int removedItem = PrioQueue.poll();
// print details
System.out.println( "Removed Element: " + removedItem);
System.out.println( "Now Queue Contains:" );
System.out.println(PrioQueue.toString());
}
} 





         








     输出：    


Removed Element: 5278367
Now Queue Contains:
[35658786, 87625142, 74381793]





     例2：    程序演示poll（）方法，从字符串值列表中删除字符串，如果列表为空，则返回null。 










                  


      


                                         


      


                    


      


                                                              






















                     // Java Program Demonstrate poll()                   


                     // method of PriorityBlockingQueue                   


                             


                     import                               java.util.concurrent.PriorityBlockingQueue;                   


                     import                               java.util.*;                   


                             


                     public                               class                               GFG {                   


                                         public                               static                               void                               main(String[] args)                   


                                         {                   


                             


                                         // define capacity of PriorityBlockingQueue                   


                                         int                               capacityOfQueue =                               5                               ;                   


                             


                                         // create object of PriorityBlockingQueue which contains                   


                                         // name of students                   


                                         PriorityBlockingQueue<String> names                   


                                         =                               new                               PriorityBlockingQueue<String>(capacityOfQueue);                   


                             


                                         // Add names of students of girls college                   


                                         names.offer(                               "Joyita"                               );                   


                                         names.offer(                               "Priyanka"                               );                   


                             


                                         // remove two names from list of names                   


                                         // and print removed name                   


                                         String removedName1 = names.poll();                   


                                         String removedName2 = names.poll();                   


                             


                                         // print details                   


                                         System.out.println(                               "Removed Name 1: "                               + removedName1);                   


                                         System.out.println(                               "Removed Name 2: "                               + removedName2);                   


                                         System.out.println(                               "Now Queue Contains:"                               );                   


                                         System.out.println(names.toString());                   


                             


                                         // try to remove from empty PriorityBlockingQueue                   


                                         String removedName3 = names.poll();                   


                                         System.out.println(                               "Removed Name 3: "                               + removedName3);                   


                                         }                   


                     }                   












  






         






         








     输出：    


Removed Name 1: Joyita
Removed Name 2: Priyanka
Now Queue Contains:
[]
Removed Name 3: null





  2.轮询（长超时，时间单位）方法 


  这个     轮询（长超时，时间单位）    方法     优先阻塞队列       从头部检索并删除元素    优先封锁队列。如果PriorityBlockingQueue为空，则它将等待指定的时间，直到元素变为可用。等待时间和时间单位作为该方法的参数。 


     语法：   


public E poll(long timeout, TimeUnit unit) throws InterruptedException


     参数：      此方法接受两个参数： 


    

  1.        超时（长）      ：放弃前等待的时间，单位为。  
    2. 

  2.        单位（时间单位）      ：确定如何解释超时参数的时间单位。  
    3. 



     返回：    此方法从PriorityBlockingQueue的头返回元素，如果指定的等待时间已过，则返回null，然后元素才可用。 


     例外情况：    此方法只引发一个异常     中断异常    –如果在等待时被打断 


  下面的程序演示了PriorityBlockingQueue的轮询（长超时、时间单位）方法： 


     例1：    程序演示PriorityBlockingQueue上的poll（长超时，时间单位）方法，以从数字列表中删除元素。 










                  


      


                                         


      


                    


      


                                                              






















                     // Java Program Demonstrate poll(long timeout, TimeUnit unit)                   


                     // method of PriorityBlockingQueue                   


                             


                     import                               java.util.concurrent.PriorityBlockingQueue;                   


                     import                               java.util.concurrent.TimeUnit;                   


                             


                     public                               class                               GFG {                   


                                         public                               static                               void                               main(String[] args)                   


                                         throws                               InterruptedException                   


                                         {                   


                             


                                         // define capacity of PriorityBlockingQueue                   


                                         int                               capacityOfQueue =                               5                               ;                   


                             


                                         // create object of PriorityBlockingQueue                   


                                         PriorityBlockingQueue<Integer> PrioQueue                   


                                         =                               new                               PriorityBlockingQueue<Integer>(capacityOfQueue);                   


                             


                                         // Add numbers to PriorityBlockingQueue                   


                                         PrioQueue.offer(                               35658786                               );                   


                                         PrioQueue.offer(                               5278367                               );                   


                             


                                         // Try to poll  elements from PriorityBlockingQueue                   


                                         System.out.println(                               "Removed Number: "                   


                                         + PrioQueue.poll(                               10                               , TimeUnit.SECONDS));                   


                                         System.out.println(                               "List Contains"                               + PrioQueue);                   


                             


                                         System.out.println(                               "Removed Number: "                   


                                         + PrioQueue.poll(                               10                               , TimeUnit.SECONDS));                   


                                         System.out.println(                               "List Contains"                               + PrioQueue);                   


                             


                                         System.out.println(                               "Removed Number: "                   


                                         + PrioQueue.poll(                               10                               , TimeUnit.SECONDS));                   


                                         System.out.println(                               "List Contains"                               + PrioQueue);                   


                                         }                   


                     }                   












  






         






         








     输出：    


Removed Number: 5278367
List Contains[35658786]
Removed Number: 35658786
List Contains[]
Removed Number: null
List Contains[]





     参考：   



 


                    

        
© 版权声明
文章版权归作者所有，未经允许请勿转载。
THE END
Java
    

    
喜欢就支持一下吧
点赞11
        分享

        

            

                
                
CPPKU的头像-yiteyi-C++库

                
            

            
VS调试报错：f:\dd\vctools\vc7libs\ship\atlmfc\src\occcont.cpp line:925的原因-yiteyi-C++库
VS调试报错：f:\dd\vctools\vc7libs\ship\atlmfc\src\occcont.cpp line:925的原因
VS调试报错：f:\dd\vctools\vc7libs\ship\atlmfc\src\occcont.cpp li...
8年前 2.6W+
关于”PostgreSQL错误：关系[表]不存在“问题的原因和解决方案-yiteyi-C++库
关于”PostgreSQL错误：关系[表]不存在“问题的原因和解决方案
关于”PostgreSQL错误：关系[表]不存在“问题的原因和解决方案
7年前 9287
Easylogging++入门教程（三）Easylogging++ 配置-yiteyi-C++库
Easylogging++入门教程（三）Easylogging++ 配置
Easylogging++入门教程（三）Easylogging++ 配置
9年前 9058
常见的小波基函数有哪些？如何选择合适的小波基函数？-yiteyi-C++库
常见的小波基函数有哪些？如何选择合适的小波基函数？
常见的小波基函数有哪些？如何选择合适的小波基函数？
8年前 8484
TiXmlDocument变量LoadFile()加载XML文档失败的原因有哪些？-yiteyi-C++库
TiXmlDocument变量LoadFile()加载XML文档失败的原因有哪些？
TiXmlDocument变量LoadFile()加载XML文档失败的原因有哪些？
10年前 6676
Easylogging++入门教程（一）Easylogging++日志库简介-yiteyi-C++库
Easylogging++入门教程（一）Easylogging++日志库简介
Easylogging++入门教程（一）Easylogging++日志库简介
9年前 6608

        

    
    

        
    



            

                
相关推荐

            
Java中的图像处理——彩色图像到负片图像的转换-yiteyi-C++库
Java中的图像处理——彩色图像到负片图像的转换
Java中的图像处理——彩色图像到负片图像的转换
3年前 262
什么是远程过程调用（RPC）？-yiteyi-C++库
什么是远程过程调用（RPC）？
什么是远程过程调用（RPC）？
4年前 207
“HTTP 404找不到”错误代码及解决方案-yiteyi-C++库
“HTTP 404找不到”错误代码及解决方案
“HTTP 404找不到”错误代码及解决方案
4年前 190
如何从Java应用程序访问MySQL数据库？-yiteyi-C++库
如何从Java应用程序访问MySQL数据库？
如何从Java应用程序访问MySQL数据库？
4年前 171
什么是字母数字？-yiteyi-C++库
什么是字母数字？
什么是字母数字？
4年前 167
编程中的源代码是什么？-yiteyi-C++库
编程中的源代码是什么？
编程中的源代码是什么？
4年前 144