java - 如何使用带有ThreadExecutor的自定义比较器实现BlockingQueue？

我正在尝试根据字符串的长度以升序运行任务。但是它没有按预期工作。这是我到目前为止尝试过的代码：

import java.util.Comparator;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class PriorityQueueTest {
    public static void main(String... args) throws InterruptedException {
        BlockingQueue<Runnable> pq = new PriorityBlockingQueue<Runnable>(5,
                new PriorityQueueComparator());
        Runner r1 = new Runner("ABC");
        Runner r2 = new Runner("AB");
        Runner r3 = new Runner("ABCD");

        Runner[] arr = new Runner[] { r1, r2, r3 };

        ThreadPoolExecutor pool = new ThreadPoolExecutor(3, 3, 0,
                TimeUnit.SECONDS, pq);

        for (int i = 0; i < arr.length; i++) {
            pool.execute(arr[i]);
        }
        pool.shutdown();

    }
}

class PriorityQueueComparator<T extends Runner> implements Comparator<T> {

    public int compare(Runner o1, Runner o2) {
        if (o1.getName().length() < o2.getName().length()) {
            return 1;
        }
        if (o1.getName().length() > o2.getName().length()) {
            return -1;
        }
        return 0;
    }

}

class Runner implements Runnable {
    private String name;

    public Runner(String sname) {
        this.name = sname;
    }

    public void run() {
        System.out.println(name);
    }

    public String getName() {
        return name;
    }

}

我希望输出是

AB
ABC
ABCD

要么

ABCD
ABC
AB

基于客户compareTo()的Comparator方法？

我猜自定义比较器没有被调用。

请帮忙。

最佳答案

PriorityQueue仅在那时对队列中的任务进行排序。不是


排序已开始的任务。
排序尚未添加的任务。
如果您有多个线程，请更改任务完成的顺序。


如果您有少量短期任务和多个线程。您不应该期望看到太多差异。