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

Java并发编程：线程池与任务调度实战示例

原创快来打我* 2024-09-11 01:48 122阅读 0赞

Java并发编程中的线程池和任务调度是两种常用的多线程管理方式。下面将通过实例详细解释这两种概念。

线程池（ThreadPool）：

线程池是一种预先创建固定数量的线程，并将其放入可重复利用的队列中，当需要执行新任务时，会从队列中取出线程进行处理，而不是每次都创建新的线程。

示例代码：

// 创建线程池
ExecutorService executor = Executors.newFixedThreadPool(5); // 限制最多同时运行的线程数
// 提交任务到线程池执行
executor.submit(() -> {
    System.out.println("Task is being executed by a worker thread.");
    // 这里可以进行需要多线程支持的任务处理
})); // 提交一个任务到线程池
// 关闭线程池，释放资源
executor.shutdown();
while (!executor.isTerminated())) {
    System.out.println("Worker threads still executing tasks.");
    try {
        Thread.sleep(1000); // 暂停1秒
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

任务调度（Task Scheduling）：

在Java中，我们可以使用各种框架如Quartz、Spring Batch等来实现任务的调度。以下以Spring Batch为例简单说明任务调度。

示例代码（基于Spring Batch）：

// 定义一个任务类
public class MyTask implements Runnable {
    @Override
    public void run() {
        System.out.println("Executing task by a worker thread.");
        // 这里可以进行需要多线程支持的任务处理
    }
}
// 创建一个批处理配置类
@Configuration
public class BatchConfig {
    // 定义一个任务，提交给批量处理
    @Bean(name = "myTaskBean"))
    public MyTask myTaskBean() {
        return new MyTask();
    }
    // 定义一个批量处理任务，配置延迟时间和最大运行次数
    @Bean(name = "batchJob")
    public Job batchJob() {
        return JobBuilder.newJob(MyTask.class)
                .incrementer(new RunIdIncrementer()) // 设置任务标识，每次运行时生成新的ID
                .setDelay(1000) // 任务延迟执行1秒
                .有限数量(3) // 最大运行次数为3次
                .build();
    }
    // 定义一个批处理启动配置
    @Bean(name = "batchJobLauncher")
    public JobLauncher batchJobLauncher() {
        return new SimpleJobLauncher(); // 使用简单的任务启动器
    }
}