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<>();
    }
}

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

/**
 * 判断此队列是否有元素 ，没有返回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());
}

}