java之Spring 框架实战: TaskExecutor

原创

IT工作者

发布于 2022-07-04 09:34:25

4070

发布于 2022-07-04 09:34:25

文章被收录于专栏：程序技术知识

1 ThreadPoolTaskExecuto

使用 ThreadPoolTaskExecutor 可以实现一个 TaskExecutor.

下面看个示例, 基于 ThreadPoolTaskExecutor 实现方法的异步调用.

写一个配置类提供线程池:

@Configuration
@ComponentScan("cn.mitrecx.learn4advance.executor")
@EnableAsync // 开启异步任务支持
public class TaskExecutorConfig implements AsyncConfigurer {
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(4);
        taskExecutor.setMaxPoolSize(8);
        taskExecutor.setQueueCapacity(16);
        taskExecutor.initialize();
        return taskExecutor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
}

需要异步执行的类/方法:

@Service
public class AsyncTaskService {
    @Async // Async 注解说明该方法是一个异步方法
    public void executeAsyncTask(Integer i) {
        System.out.println("执行异步任务: " + i);
    }

    @Async
    public void executeAsyncTask2(Integer i) {
        System.out.println("执行异步任务2=====: " + i);
    }
}

启动类:

public static void main(String[] args) {
    AnnotationConfigApplicationContext context =
            new AnnotationConfigApplicationContext(TaskExecutorConfig.class);

    AsyncTaskService asyncTaskService = context.getBean(AsyncTaskService.class);

    for (int i = 0; i < 10; i++) {
        asyncTaskService.executeAsyncTask(i);
        asyncTaskService.executeAsyncTask2(i);
    }

    context.close();
}

执行结果:

执行异步任务: 0

执行异步任务2=====: 1

执行异步任务: 2

执行异步任务: 1

执行异步任务2=====: 0

执行异步任务2=====: 2

.....

可以看到, 被 @Async 注解的方法是异步执行的.

这里是源码.

2 定时任务

@Scheduled 注解支持定时任务, 可选的参数主要有:

fixedDelay, 指定任务执行的时间间隔(上一个任务结束到下一个任务开始的间隔)

fixedRate, 指定任务执行的时间间隔(上一个任务开始到下一个任务开始的间隔, 若任务的执行时间X毫秒超过了 fixedRate 毫秒, 那么下一个任务会在 X 毫秒后执行)

cron, 指定具体的时间点, 比如每天晚上10点执行.

示例代码如下.

直接在需要定时执行的方法上加上 @Scheduled 注解即可:

@Service
public class ScheduledTaskService {
    private static final SimpleDateFormat df = new SimpleDateFormat("HH:mm:ss");

    @Scheduled(fixedDelay = 5000)
    public void reportCurrentTime() {
        System.out.println("每隔5秒执行一次 " + df.format(new Date()));
        try {
            Thread.sleep(6000); // 每隔 11 秒执行一次
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @Scheduled(cron = "0 28 11 ? * *") // 每天11点28分执行
    public void fixTimeExecution() {
        System.out.println("在指定的时间 " + df.format(new Date()) + " 执行");
    }
}

配置类:

@Configuration
@ComponentScan("cn.mitrecx.learn4advance.scheduler")
@EnableScheduling
public class TaskSchedulerConfig {
}

主程序:

public static void main(String[] args) {
    AnnotationConfigApplicationContext context =
            new AnnotationConfigApplicationContext(TaskSchedulerConfig.class);
}

原创声明：本文系作者授权腾讯云开发者社区发表，未经许可，不得转载。

如有侵权，请联系 cloudcommunity@tencent.com 删除。

java