异步线程

1、启动类需要加上@EnableAsync注解,开启异步

@SpringBootApplication
@EnableAutoConfiguration(exclude = {MultipartAutoConfiguration.class})
@ComponentScan(basePackages = "com.asia")
@MapperScan("com.asia.dao")
@EnableAsync
public class WebApplication {
    public static void main(String[] args){
       SpringApplication.run(WebApplication.class,args);
    }
}

2、编写异步线程,加上@Async注解才能实现异步

@Component
public class TaskProcessService {
    Logger logger = LoggerFactory.getLogger(TaskProcessService.class);

    @Async
    public void threadAsyc(){
        try {
            Executors.newSingleThreadExecutor().execute(new Runnable() {
                @Override
                public void run() {
                    for (int i = 1; i < 1200; i++) {
                        logger.info("-----异步执行中-----" + i);
                    }
                }
            });
            Thread.sleep(5 * 1000);
        }catch (Exception e){

        }

    }

3、多节点(没有进程机情况下用redis来锁KEY)执行调度异步方法时,需要加锁而且要把锁的KEY放到redis,这样多节点获取锁也不会报错

4、测试异步线程类

@GetMapping("/threadAsyc")
public String threadAsyc(){
    logger.info("----异步线程开始------");
    try {
        taskProcessService.threadAsyc();
        logger.info("----异步线程结束------");
    }catch (Exception e){

    }
    return "succ";
}

版权声明:本文为weixin_45958605原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。