BlockingQueue初体验
BlockingQueue初体验
zhengjunbo 发表于3年前
BlockingQueue初体验
  • 发表于 3年前
  • 阅读 9
  • 收藏 0
  • 点赞 0
  • 评论 0
摘要: 记录下BlockingQueue的一些使用方法


阻塞队列,测试了下优先级队列,以下是测试代码,在队列中用以,优先充值或者发送短信的时候使用。

@Test
    public void testPriorityBlockingQueue() throws InterruptedException {
        StudentComparator studentComparator = new StudentComparator();
        BlockingQueue<Student> blockingQueue = new PriorityBlockingQueue<Student> (10,studentComparator);
        Student student1 = new Student();
        student1.setId(1);
        student1.setName("学生1");
        Student student2 = new Student();
        student2.setId(3);
        student2.setName("学生3");
        Student student3 = new Student();
        student3.setId(2);
        student3.setName("学生2");
        blockingQueue.offer(student1);
        blockingQueue.offer(student2);
        blockingQueue.offer(student3);
        while(true){
            Student student= blockingQueue.take();
            System.out.println(student);
        }

    }

    class Student {
        private int id;
        private String name;

        public int getId() {
            return id;
        }

        public void setId(int id) {
            this.id = id;
        }

        public String getName() {
            return name;
        }

        public void setName(String name) {
            this.name = name;
        }

        @Override
        public String toString() {
            return "Student{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    '}';
        }
    }

    class StudentComparator implements Comparator<Student>{

        @Override
        public int compare(Student o1, Student o2) {
            if(o1.getId()<=o2.getId()){
                return 1;
            }
            return -1;
        }
    }



共有 人打赏支持
粉丝 2
博文 27
码字总数 10871
×
zhengjunbo
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: