Java线程队列的使用-PriorityBlockingQueue

妖狐艹你老母 2023-10-12 23:11 70阅读 0赞

PriorityBlockingQueue是一种带优先级的无界阻塞队列，它的元素必须实现Comparable接口，或者在创建时指定一个Comparator对象。它会根据元素的优先级顺序进行排序，优先级高的元素先被获取。

PriorityBlockingQueue可以用于实现优先级任务调度，例如下面的代码创建了一个PriorityBlockingQueue，并向其中添加了四个任务，每个任务有不同的优先级。然后从队列中循环获取任务，并打印出来。

  1. import java.util.concurrent.PriorityBlockingQueue;
  3. // 定义一个任务类，实现Comparable接口
  4. class Task implements Comparable<Task> {
  5.     // 任务名称
  6.     private String name;
  7.     // 任务优先级
  8.     private int priority;
  10.     // 构造方法，传入任务名称和优先级
  11.     public Task(String name, int priority) {
  12.         this.name = name;
  13.         this.priority = priority;
  14.     }
  16.     @Override
  17.     public int compareTo(Task o) {
  18.         // 比较优先级，优先级大的排在前面
  19.         return Integer.compare(o.priority, this.priority);
  20.     }
  22.     @Override
  23.     public String toString() {
  24.         return "Task{" +
  25.                 "name='" + name + '\'' +
  26.                 ", priority=" + priority +
  27.                 '}';
  28.     }
  29. }
  31. public class PriorityBlockingQueueDemo {
  32.     public static void main(String[] args) {
  33.         // 创建一个优先级阻塞队列
  34.         PriorityBlockingQueue<Task> pbq = new PriorityBlockingQueue<>();
  35.         // 向队列中添加四个任务，注意它们的优先级
  36.         pbq.offer(new Task("task1", 5));
  37.         pbq.offer(new Task("task2", 2));
  38.         pbq.offer(new Task("task3", 7));
  39.         pbq.offer(new Task("task4", 3));
  40.         // 从队列中循环获取任务，并打印出来
  41.         while (pbq.size() > 0) {
  42.             try {
  43.                 System.out.println(pbq.take());
  44.             } catch (InterruptedException e) {
  45.                 e.printStackTrace();
  46.             }
  47.         }
  48.     }
  49. }

输出结果：

  1. Task{name='task3', priority=7}
  2. Task{name='task1', priority=5}
  3. Task{name='task4', priority=3}
  4. Task{name='task2', priority=2}

可以看到，队列中的任务按照优先级的顺序被获取，即先获取优先级最高的任务，后获取优先级最低的任务。

发表评论

表情：
评论列表 （有 0 条评论，70人围观）

还没有评论，来说两句吧...

相关阅读