在Java中如何实现线程安全的任务优先级排序_任务优先级排序线程安全处理技巧说明

class Task implements Comparable<Task> {
    private int priority;
    private String name;

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

    @Override
    public int compareTo(Task other) {
        return Integer.compare(this.priority, other.priority); // 优先级数值越小，优先级越高
    }

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

// 使用PriorityBlockingQueue
PriorityBlockingQueue<Task> taskQueue = new PriorityBlockingQueue<>();

// 线程1：添加任务
new Thread(() -> {
    taskQueue.offer(new Task(3, "Low Priority"));
    taskQueue.offer(new Task(1, "High Priority"));
}).start();

// 线程2：取出任务执行
new Thread(() -> {
    try {
        Task task = taskQueue.take(); // 阻塞等待直到有任务可用
        System.out.println("Executing: " + task);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
}).start();

private final PriorityQueue<Task> queue = new PriorityQueue<>();
private final Object lock = new Object();

public void addTask(Task task) {
    synchronized (lock) {
        queue.offer(task);
    }
}

public Task takeTask() throws InterruptedException {
    synchronized (lock) {
        while (queue.isEmpty()) {
            lock.wait();
        }
        Task task = queue.poll();
        lock.notifyAll();
        return task;
    }
}

ExecutorService executor = new ThreadPoolExecutor(
    2, 5, 60L, TimeUnit.SECONDS,
    new PriorityBlockingQueue<>()
);