Java并发编程：线程池与任务调度案例-蒲公英云

Java并发编程：线程池与任务调度案例

原创比眉伴天荒 2024-11-29 11:15 83阅读 0赞

在Java的并发编程中，线程池和任务调度是非常重要的概念。下面我们将通过一个实际案例来理解它们。

首先，我们创建一个简单的任务类：

public class Task implements Runnable {
    private String message;
    public Task(String message) {
        this.message = message;
    }
    @Override
    public void run() {
        System.out.println("Task: " + message);
    }
}

接下来，我们将使用ThreadPoolExecutor创建一个线程池，并进行任务调度：

import java.util.concurrent.*;
public class ThreadPoolExample {
    private static final int THREAD_COUNT = 5; // 线程池大小
    public static void main(String[] args) {
        // 创建线程池
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                THREAD_COUNT, // 核心线程数
                Integer.MAX_VALUE, // 线程最大数量，可无限
                60L, // 单位：秒，任务执行超时时间
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(10) // 工作队列，用于存放等待的任务
        );
        // 提交任务到线程池
        for (int i = 0; i < 20; i++) {
            String message = "Task " + i;
            executor.execute(new Task(message)));
        }
        // 关闭线程池
        executor.shutdown();
    }
}