java PriorityQueue不排序，有时会引发异常

Question

我运行请求线程

Task t = new Task(s1, s2, c, p);

Requestor req = new Requestor(queue, t);
req.start();

它将任务添加到队列并运行服务线程

queue.add(task); // my class

Service ser = new Service(queue);
ser.start();

添加方法

public void add(Task t) {
    synchronized (mutex) {
        queue.add(t); // PriorityQueue<Task>

        list.clear(); // DefaultListModel

        for (Task ta : queue)
            list.addElement(ta);
    }
}

服务的运行方法

    task = queue.pop(); // my class
...
    queue.add(task);

流行方法

public Task pop() {
    synchronized (mutex) {
        ArrayList<Task> al = new ArrayList<Task>();

        Task tmp = queue.remove();
        al.add(tmp);

        while (tmp.isFinish() && !queue.isEmpty()) {
            tmp = queue.remove();
            al.add(tmp);
        }

        al.remove(al.size()-1);

        for (Task t : al) {
            queue.add(t);
        }

        list.clear();

        for (Task ta : queue)
            list.addElement(ta);

        return tmp;
    }
}

队列变量是

    Comparator<Task> cmp = new TaskComparator();

    queue = new PriorityQueue<Task>(20, cmp);

比较器

 public class TaskComparator implements Comparator<Task> {

@Override
public int compare(Task o1, Task o2) {
    return o1.getPriority() - o2.getPriority();
}

}

一般来说，这种优先级队列是随机排序的，有时我可以看到

Exception in thread "AWT-EventQueue-0" java.lang.ArrayIndexOutOfBoundsException: 1 >= 0
at java.util.Vector.elementAt(Vector.java:427)
at javax.swing.DefaultListModel.getElementAt(DefaultListModel.java:70)
...

----编辑 桂

private Queue queue;
...
    _add.addActionListener(new ActionListener() {

        @Override
        public void actionPerformed(ActionEvent e) {
...
            Task t = new Task(s1, s2, c, p);

            Requestor req = new Requestor(queue, t);
            req.start();
        }
    });
...
    JScrollPane scrollPane = new JScrollPane();
    contentPane.add(scrollPane, BorderLayout.CENTER);

    DefaultListModel model = new DefaultListModel();

    JList _list = new JList(model);
    scrollPane.setViewportView(_list);

    queue = new Queue(model);

——编辑

我实现了与任务类相当的功能。如果我返回1，它总是在底部添加新的o元素，当我返回-1时，它总是在顶部添加新元素，但当

@Override
public int compareTo(Task o) {
    if (pr == o.getPriority())
        return 0;
    else if (pr > o.getPriority())
        return 1;
    else
        return -1;
}

它可以随心所欲

Answer 1

唯一按顺序返回PriorityQueue的方法是remove()。迭代它不会按顺序返回元素。参见Javadoc

Answer 2

PriorityQueue是一个堆，当您使用remove（）方法时，它正在重建

public void add(Task t) {
    synchronized (mutex) {
        queue.add(t);

        list.clear();

        ArrayList<Task> al = new ArrayList<Task>();

        while (queue.size() > 0)
            al.add(queue.remove());

        for (Task ta : al) {
            list.addElement(ta);
            queue.add(ta);
        }
    }
}