java 异步调用处理
发布日期:2022-02-25 01:17:42 浏览次数:47 分类:技术文章

本文共 873 字,大约阅读时间需要 2 分钟。

设置线程池@Bean("myThread")// 线程池    public TaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); // 设置核心线程数 executor.setCorePoolSize(10); // 设置最大线程数 executor.setMaxPoolSize(20); // 设置队列容量 executor.setQueueCapacity(100); // 设置线程活跃时间(秒) executor.setKeepAliveSeconds(60); // 设置默认线程名称 executor.setThreadNamePrefix("importThread-"); // 设置拒绝策略 executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 等待所有任务结束后再关闭线程池 executor.setWaitForTasksToCompleteOnShutdown(true); return executor; }1、类形式调用 (创建sevice接口) @Async("myThread") // 对应线程池里的bean public void doto(InputStream inputStream) {
//todo } 2、直接调用 taskExecutor.taskExecutor().execute(() -> this.dotoSomething(int userId));

转载地址:https://blog.csdn.net/qq_37741426/article/details/122555324 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:基于redis实现分布式锁
下一篇:java实现自定义注解校验重复提交(亲测有效)

发表评论

最新留言

做的很好,不错不错
[***.243.131.199]2024年04月09日 18时14分03秒