Java Queue队列如何进行任务调度

在Java中，可以使用java.util.concurrent包中的Queue接口和相关的实现类来实现任务调度。这里有一个简单的例子，使用PriorityBlockingQueue和ThreadPoolExecutor来实现任务调度。

首先，创建一个任务类，实现Runnable接口：

import java.util.concurrent.Callable;

public class Task implements Callable<Void> {
    private int priority;
    private String name;

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

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

接下来，创建一个比较器，用于比较任务的优先级：

import java.util.Comparator;

public class TaskComparator implements Comparator<Task> {
    @Override
    public int compare(Task t1, Task t2) {
        return Integer.compare(t1.getPriority(), t2.getPriority());
    }
}

现在，可以使用PriorityBlockingQueue来存储任务，并使用ThreadPoolExecutor来执行任务：

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

public class TaskScheduler {
    public static void main(String[] args) {
        PriorityBlockingQueue<Task> taskQueue = new PriorityBlockingQueue<>(10, new TaskComparator());
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 添加任务到队列
        taskQueue.put(new Task(3, "任务1"));
        taskQueue.put(new Task(1, "任务2"));
        taskQueue.put(new Task(2, "任务3"));

        // 从队列中取出任务并执行
        while (!taskQueue.isEmpty()) {
            try {
                Task task = taskQueue.take();
                executorService.submit(task);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        // 关闭线程池
        executorService.shutdown();
    }
}

在这个例子中，我们创建了一个PriorityBlockingQueue来存储任务，并使用ThreadPoolExecutor来执行任务。任务类实现了Callable接口，这样我们可以获取任务的执行结果。我们还创建了一个比较器TaskComparator来比较任务的优先级。

当需要添加任务时，可以将任务添加到PriorityBlockingQueue中。线程池会自动从队列中取出任务并执行。这样可以实现简单的任务调度功能。