SpringBoot @PostConstruct 异步不阻塞主线程启动

SpringBoot @PostConstruct 异步不阻塞主线程启动

因为项目中 @PostConstruct   初始化方法中的逻辑比较久， 阻塞了主线程， 耽误启动时间，就想者优化一下， 周末查了一下解决了。

上代码：

禁止在项目中  new  Thread();

1： 配置项目线程池:   

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor;


@Configuration
public class ThreadExecutorConfig {

    private final Logger logger = LoggerFactory.getLogger(this.getClass());
    
    private int corePoolSize = 10;
    
    private int maxPoolSize = 200;
    
    private int queueCapacity = 10;

    @Bean("testAsync")
    public ExecutorService testFxbDrawExecutor(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(corePoolSize);
        executor.setMaxPoolSize(maxPoolSize);
        executor.setQueueCapacity(queueCapacity);
        executor.setThreadNamePrefix("testAsync");

        // rejection-policy：当pool已经达到max size的时候，如何处理新任务
        // CALLER_RUNS：不在新线程中执行任务，而是由调用者所在的线程来执行
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 执行初始化
        executor.initialize();
        return executor.getThreadPoolExecutor();
    }

}

2： 异步方法：

public interface TestService {

    void test();
}

import com.xxxx.service.TestService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;


@Service
@Slf4j
@Lazy(false)
public class TestServiceImpl implements TestService {


    @Async("testAsync")  //指定线程池
    @Override
    public void test() {
        System.out.println("------------------------异步方法开始 " + Thread.currentThread().getName());
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("----------------异步方法执行完了" + Thread.currentThread().getName());
    }
}

3： @ PostConstruct  调用异步方法,    注意，  PostConstruct  不能在同一个类中调@async

import com.xxxx.service.TestService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;


@Service
public class LooooServiceImpl {


    @Autowired
    private TestService testService;


    @PostConstruct
    public void test(){
        System.out.println("-1111111111111111111111111111111111");
        testService.test();
        System.out.println("-2222222222222222222222222222222222");
    }
}

4： 启动类加上 启用异步

 

5： 执行结果：

错误请忽略。。。。