ConcurrentLinkedQueue学习记

package concurrentLinkedQueueTest;



 public class User {



     private String userName;

     private String password;



     public String getUserName() {

         return userName;

     }



     public void setUserName(String userName) {

         this.userName = userName;

     }



     public String getPassword() {

         return password;

     }



     public void setPassword(String password) {

         this.password = password;

     }

}

package concurrentLinkedQueueTest;


 import java.util.Queue;
 import java.util.concurrent.ConcurrentLinkedQueue;


 public class ConcurrentLinkedQueueTest {


     private static Queue<User> queue;


     // 基于链接节点的无界线程安全队列
     static {
         if (null == queue) {
             queue = new ConcurrentLinkedQueue<User>();
         }
     }


     /**
      * 初始化创建队列
      */
     public static void init() {
         if (null == queue) {
             queue = new ConcurrentLinkedQueue<User>();
         }
     }


     /**
      * 判断此队列是否有元素 ，没有返回true
      * 
      * @return
      */
     public static boolean isEmpty() {
         return (queue.isEmpty());
     }


     /**
      * 添加到队列方法，将指定元素插入此队列的尾部。
      * 
      * @param u User对象
      * @return 成功返回true，否则抛出 IllegalStateException
      */
     public static boolean add(User u) {
         return (queue.add(u));
     }


     /**
      * 获取并移除此队列的头 ，如果此队列为空，则返回 null
      * 
      * @return
      */
     public static User getPoll() {
         return (queue.poll());
     }


     /**
      * 获取但不移除此队列的头；如果此队列为空，则返回 null
      * 
      * @return
      */
     public static User getPeek() {
         return (queue.peek());
     }


     /**
      * 获取size,速度比较慢
      * 
      * @return
      */
     public static int getQueueSize() {
         return (queue.size());
     }


     public static void main(String[] args) {
         // 先判断队列是否有数据
         System.out.println("队列是否为空：" + !isEmpty());
         // 添加数据
         User u1 = new User();
         u1.setPassword("3333");
         u1.setUserName("zhangsan");
         queue.add(u1);
         // 再次判断队列是否有数据
         System.out.println("队列是否为空：" + !isEmpty());
         // 查看队列有多少条数据
         System.out.println("队列数据条数：" + getQueueSize());
         User u2 = new User();
         u2.setPassword("4444");
         u2.setUserName("lisi");
         queue.add(u2);
         User u4 = new User();
         u4.setPassword("5555");
         u4.setUserName("王五");
         queue.add(u4);
         User u3 = getPeek();
         System.out.println("userName=" + u3.getUserName() + ",password=" + u3.getPassword());
         // 把未删除的数据打印出来
         for (int i = 0; i < 3; i++) {
             User u5 = getPoll();
             if (u5 != null) {
                 System.out.println("\n获取队列数据并删除：" + u5.getUserName() + "---" + u5.getPassword());
             }
         }
         // 再次查看队列有多少条数据
         System.out.println("队列数据条数：" + getQueueSize());
     }


 }