Java之@Schedule与@Async注解失效问题总结

 更新时间:2026年05月09日 08:32:30   作者:想去22世纪  
文章主要讨论了Spring中@Scheduled和@Async注解的使用场景及问题,@Scheduled方法需被Spring管理,@Async注解可能因线程池问题导致异步失效,建议在测试类中使用自动装配确保生效

Schedule注解失效

Schedule标记的方法的类没有被spring托管

当@Scheduled方法所属的类没有使用@Component,@Service,@Controller等修饰的时候定时任务不执行,当两个定时任务同时执行时,两个定时任务随机先后执行

/**
 * 当前类不交给spring托管,定时任务失效
 * 两个定时任务同一个时间点,谁先抢到锁谁先执行
 */
@Component
public class ScheduleOne {
    @Scheduled(cron = "0 22 * * * ? ")
    public void test1() {
        for (int i = 0; i < 10; i++) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("子线程名:"+Thread.currentThread().getName());
            System.out.println(String.format("第%d次执行任务一",i));
        }
    }
    @Scheduled(cron = "0 22 * * * ? ")
    public void test2() {
        for (int i = 0; i < 10; i++) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("子线程名:"+Thread.currentThread().getName());
            System.out.println(String.format("第%d次执行任务二",i));
        }
    }
}

@Async注解失效

异步任务等同于开启了一个线程池,也可以自定义线程池

同类中调用异步方法,异步功能失效

    @Async("asyncExecutors")
    public void java() {
        System.out.println("-----------------------------------------------------elegant separator-----------------------------------------------------------------");
        for (int i = 0; i < 10; i++) {
            try {
                Thread.sleep(1000);
                System.out.println("Async++++++++子线程java名:"+Thread.currentThread().getName());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(i + "hello java");
        }
        System.out.println("-----------------------------------------------------elegant separator-----------------------------------------------------------------");
    }
    @Test
    public void getJava() {
        java();
        System.out.println("异步任务执行成功了吗");
    }

执行结果:

通过测试方法调用异步方法异步失效

    @Async
    public void python() {
        for (int i = 0; i < 10; i++) {
            try {
                Thread.sleep(1000);
                System.out.println("Async++++++++子线程java名:"+Thread.currentThread().getName());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(i + "hello python");
        }
    }
    
    @Test
    public void getPython() {

        PrintOne printOne = new PrintOne();
        printOne.python();
        System.out.println("异步任务执行成功了吗");
    }

通过new对象调用异步方法异步失效

    @RequestMapping(method = RequestMethod.GET,value = "three")
    public String test3() {
        PrintOne printOne1 = new PrintOne();
        printOne1.python();
        System.out.println("主线程名"+ Thread.currentThread().getName());
        return "方法返回值";
    }

测试类中异步方法压根不会进入

@SpringBootTest
@RunWith(SpringRunner.class)
public class AsyncTest {
    /**
     * 测试类中异步方法不执行
     */
    @Resource
    PrintOne printOne;
    @Test
    public void test1() {
        printOne.python();
        System.out.println("异步任务执行了吗");
    }
}

类被spring托管

且使用自动装配的方式调用才可以生效,且不在测试类中注解生效

    @RequestMapping(method = RequestMethod.GET,value = "one")
    public String test2() {
        printOne.java();
        System.out.println("主线程名"+ Thread.currentThread().getName());
        return "方法返回值";
    }

执行结果

@Schedule与@Async同时存在

两个任务可以交替执行

@Service
public class ScheduledThree {
    @Scheduled(cron = "0 45 * * * ? ")
    @Async
    public void test1() {
        for (int i = 0; i < 20; i++) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("ScheduleThree-----子线程1名:"+Thread.currentThread().getName());
        }
    }
    @Scheduled(cron = "0 45 * * * ? ")
    @Async
    public void test2() {
        for (int i = 0; i < 20; i++) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("ScheduleThree-----子线程2名:"+Thread.currentThread().getName());
        }
    }
}

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • idea配置连接数据库的超详细步骤

    idea配置连接数据库的超详细步骤

    这篇文章主要介绍了idea配置连接数据库的超详细步骤,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-12-12
  • kettle中使用js调用java类的方法

    kettle中使用js调用java类的方法

    这篇文章主要介绍了kettle中使用js调用java类的方法,本文讲解了注意事项和调用语法,需要的朋友可以参考下
    2015-05-05
  • Spring中bean标签的用法详解

    Spring中bean标签的用法详解

    Bean标签一般用于配置对象交由Spring 来创建,这篇文章主要来和大家详细聊聊Spring中bean标签的用法,感兴趣的小伙伴可以跟随小编一起学习一下
    2023-06-06
  • Java中Equals使用方法汇总

    Java中Equals使用方法汇总

    这篇文章主要采用问答的方式集中讲解了Java中Equals的使用方法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-02-02
  • 使用Mybatis接收Integer参数的问题

    使用Mybatis接收Integer参数的问题

    这篇文章主要介绍了使用Mybatis接收Integer参数的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-03-03
  • Jmeter对响应数据实现断言代码实例

    Jmeter对响应数据实现断言代码实例

    这篇文章主要介绍了Jmeter对响应数据实现断言代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-09-09
  • 详解SpringMVC和MyBatis框架开发环境搭建和简单实用

    详解SpringMVC和MyBatis框架开发环境搭建和简单实用

    这篇文章主要介绍了详解SpringMVC和MyBatis框架开发环境搭建和简单实用,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-05-05
  • k8s部署springboot实现前后端分离项目

    k8s部署springboot实现前后端分离项目

    本文主要介绍了k8s部署springboot实现前后端分离项目,主要包括配置文件、镜像构建和容器编排等方面,具有一定的参考价值,感兴趣的可以了解一下
    2024-01-01
  • Spring Data Jpa返回自定义对象的3种方法实例

    Spring Data Jpa返回自定义对象的3种方法实例

    在使用Spring Data Jpa框架时,根据业务需求我们通常需要进行复杂的数据库查询,下面这篇文章主要给大家介绍了关于Spring Data Jpa返回自定义对象的3种方法,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2022-08-08
  • elasticsearch通过guice注入Node组装启动过程

    elasticsearch通过guice注入Node组装启动过程

    这篇文章主要为大家介绍了 elasticsearch通过guice注入Node组装启动过程,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-04-04

最新评论