在Java中实现并发任务队列，解决线程调度与资源管理问题

原创 ╰+哭是因爲堅強的太久メ 2024-11-06 18:05 20阅读 0赞

在Java中实现并发任务队列，通常可以使用`ExecutorService`框架来管理线程池和任务队列。`ExecutorService`提供了一种方便的方式来异步执行任务，并且可以控制并发级别和资源管理。下面是一个简单的示例，展示如何使用`ExecutorService`来实现一个并发任务队列：

```javaimport java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ConcurrentTaskQueue {

public static void main(String[] args) {
// 创建一个固定大小的线程池ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池 for (int i =0; i <10; i++) {
 final int taskId = i;
 executor.submit(() -> {
 try {
//模拟任务执行时间 TimeUnit.SECONDS.sleep(2);
 System.out.println("Task " + taskId + " completed.");
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
 }
 });
 }

// 关闭ExecutorService，不接受新任务，已提交的任务继续执行 executor.shutdown();

//等待所有任务完成 try {
if (!executor.awaitTermination(1, TimeUnit.MINUTES)) {
// 超时后取消当前未完成的任务 executor.shutdownNow();
 }
} catch (InterruptedException ex) {
//重新设置中断状态Thread.currentThread().interrupt();
//取消当前未完成的任务 executor.shutdownNow();
 }

System.out.println("All tasks completed.");
 }
}
```在这个示例中，我们创建了一个固定大小为5的线程池，这意味着同时最多有5个任务在执行。我们提交了10个任务到线程池中，每个任务简单地休眠2秒钟并打印一条消息。`ExecutorService`会自动管理这些任务的执行，包括线程的创建和销毁。

`shutdown()`方法用于关闭`ExecutorService`，不再接受新任务，但已提交的任务会继续执行直到完成。`awaitTermination()`方法用于等待所有任务完成，或者直到超时。如果超时，我们调用`shutdownNow()`来尝试取消当前未完成的任务。

这个简单的示例展示了如何使用Java的并发框架来实现一个并发任务队列，以及如何进行基本的线程调度和资源管理。根据实际需求，你可能需要更复杂的逻辑来处理任务的优先级、任务的取消、异常处理等。