### 优先级队列PriorityBlockingQueue
- PriorityBlockingQueue是一个无界的基于数组的优先级阻塞队列，是线程安全的。
- 数组的默认长度是11，虽然指定了数组的长度，但是可以无限的扩充，直到资源消耗尽为止。 
- 每次出队都返回优先级别最高的或者最低的元素。
- 默认情况下元素采用自然顺序升序排序，当然我们也可以通过构造函数来指定Comparator来对元素进行排序。
- PriorityBlockingQueue不能保证同优先级元素的顺序。

代码如下：
用户model：
```java
	public UserInfo(Integer id, String userName, Integer deptId,Integer vipFlag) {
		super();
		this.id = id;
		this.userName = userName;
		this.deptId = deptId;
		this.vipFlag = vipFlag;
	}

```

```java

import com.mystudy.model.UserInfo;

import java.util.Comparator;
import java.util.concurrent.PriorityBlockingQueue;

/**
 * @ description: 优先级队列PriorityBlockingQueue：
 PriorityBlockingQueue是一个无界的基于数组的优先级阻塞队列，是线程安全的。
 数组的默认长度是11，虽然指定了数组的长度，但是可以无限的扩充，直到资源消耗尽为止。
 每次出队都返回优先级别最高的或者最低的元素。
 默认情况下元素采用自然顺序升序排序，当然我们也可以通过构造函数来指定Comparator来对元素进行排序。
 PriorityBlockingQueue不能保证同优先级元素的顺序。
 *
 */
public class PriorityBlockingQueueTest {
    public static void main(String args[]) throws InterruptedException {
        //PriorityBlockingQueue queue = new PriorityBlockingQueue(5);
        System.out.println("=================按人的ID顺办理业务==================");
        PriorityBlockingQueue<UserInfo> queue = new PriorityBlockingQueue<UserInfo>(5, new Comparator<UserInfo>() {
            @Override
            public int compare(UserInfo o1, UserInfo o2) {
                return o1.getId()-o2.getId();
            }
        });

queue.add(new UserInfo(3,"小明",1,0));
        queue.add(new UserInfo(2,"小杨",1,0));
        queue.add(new UserInfo(1,"小张",1,1));
        queue.add(new UserInfo(4,"小王",1,1));
        while (true){
            UserInfo poll = queue.poll();
            if(poll == null){
                System.out.println("没有人来办理业务，下班！");
                break;
            }
            String id = poll.getId()+"：";
            System.out.println(id +poll.getUserName()+"来办理业务啦！");
        }

System.out.println("=================VIP有优先权办理业务==================");
        PriorityBlockingQueue<UserInfo> queue2 = new PriorityBlockingQueue<UserInfo>(5, new Comparator<UserInfo>() {
            @Override
            public int compare(UserInfo o1, UserInfo o2) {
                //vip为1，普通用户为0，所以要降序排序
                return o2.getVipFlag() - o1.getVipFlag();
            }
        });

queue2.add(new UserInfo(3,"小明",1,0));
        queue2.add(new UserInfo(2,"小杨",1,0));
        queue2.add(new UserInfo(1,"小张",1,1));
        queue2.add(new UserInfo(4,"小王",1,1));
        while (true){
            UserInfo poll = queue2.poll();
            if(poll == null){
                System.out.println("没有人来办理业务，下班！");
                break;
            }
            String vipStr = poll.getVipFlag() == 1 ? "VIP用户：":"普通用户：";
            System.out.println(vipStr+poll.getUserName()+"来办理业务啦！");
        }
    }
}

```
执行结果：
```
=================按人的ID顺办理业务==================
1：小张来办理业务啦！
2：小杨来办理业务啦！
3：小明来办理业务啦！
4：小王来办理业务啦！
没有人来办理业务，下班！
=================VIP有优先权办理业务==================
VIP用户：小张来办理业务啦！
VIP用户：小王来办理业务啦！
普通用户：小明来办理业务啦！
普通用户：小杨来办理业务啦！
没有人来办理业务，下班！
```

ClassInstance

java阻塞的线程安全的优先级队列PriorityBlockingQueue

相关文章

推荐文章

热门文章

标签列表