Java ExecutorService如何实现任务优先级排序

在Java中，ExecutorService本身并不直接支持任务的优先级排序。但是，你可以使用PriorityBlockingQueue作为任务队列，并自定义一个实现了Comparable接口的任务类来实现任务优先级排序。

以下是一个简单的示例：

1. 首先，创建一个实现了Runnable接口的任务类，并实现Comparable接口以定义任务优先级：

import java.util.concurrent.Callable;

public class PriorityTask implements Callable<Void>, Comparable<PriorityTask> {
    private int priority;
    private String name;

    public PriorityTask(int priority, String name) {
        this.priority = priority;
        this.name = name;
    }

    @Override
    public Void call() {
        System.out.println("执行任务: " + name + "，优先级: " + priority);
        return null;
    }

    @Override
    public int compareTo(PriorityTask other) {
        return Integer.compare(this.priority, other.priority);
    }
}

2. 创建一个使用PriorityBlockingQueue的ThreadPoolExecutor：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class PriorityExecutorService {
    public static void main(String[] args) {
        PriorityBlockingQueue<Runnable> queue = new PriorityBlockingQueue<>();
        ExecutorService executorService = new ThreadPoolExecutor(
                5,
                10,
                60L,
                TimeUnit.SECONDS,
                queue
        );

        executorService.submit(new PriorityTask(3, "任务1"));
        executorService.submit(new PriorityTask(1, "任务2"));
        executorService.submit(new PriorityTask(5, "任务3"));
        executorService.submit(new PriorityTask(2, "任务4"));
        executorService.submit(new PriorityTask(4, "任务5"));

        executorService.shutdown();
    }
}

在这个示例中，我们创建了一个PriorityBlockingQueue，并将其作为任务队列传递给ThreadPoolExecutor。当我们向ExecutorService提交任务时，它们会根据优先级进行排序。优先级较高的任务将优先执行。

注意：这个示例使用了Callable接口而不是Runnable接口，因为Callable接口允许任务返回结果。如果你不需要任务返回结果，可以将Callable替换为Runnable。