直接上代碼

線程配置類

package zengmg.nbpi.com.thread;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.Executor;/*** @Auther 松門一枝花* @Date 2020/5/28*/
@Configuration
@EnableAsync  // 啟用異步任務
public class AsyncConfiguration {// 聲明一個線程池(并指定線程池的名字)@Bean("nbpiTaskExecutor")public Executor asyncExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();//核心線程數：線程池創建時候初始化的線程數executor.setCorePoolSize(5);//最大線程數：線程池最大的線程數，只有在緩沖隊列滿了之后才會申請超過核心線程數的線程executor.setMaxPoolSize(500);//允許線程的空閑時間60秒：當超過了核心線程出之外的線程在空閑時間到達之后會被銷毀executor.setKeepAliveSeconds(60);//線程池名的前綴：設置好了之后可以方便我們定位處理任務所在的線程池executor.setThreadNamePrefix("DailyAsync-");executor.initialize();return executor;}
}

服務類

package zengmg.nbpi.com.thread;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;/*** @Auther 松門一枝花* @Date 2020/5/28*/
@Service
public class CustomMultiThreadingService {private static final Logger logger = LoggerFactory.getLogger(CustomMultiThreadingService.class);/*如何讓異步調用的執行任務使用這個線程池中的資源來運行呢？方法非常簡單，我們只需要在@Async注解中指定線程池名即可*/@Async("nbpiTaskExecutor")public void executeAysncTask(Integer i) throws InterruptedException {logger.info("CustomMultiThreadingService ==> executeAysncTask1 method: 執行異步任務{} ", i);Thread.sleep(500L);}}

控制類

package zengmg.nbpi.com.thread;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;/*** @Auther 松門一枝花* @Date 2020/5/28*/
@Controller
@RequestMapping(value="/multithreading")
public class CustomMultiThreadingController {@Autowiredprivate CustomMultiThreadingService customMultiThreadingService;@ResponseBody@RequestMapping("/dotask")public String doTask() {try {for (int i=0;i<100000;i++){customMultiThreadingService.executeAysncTask(i);}} catch (InterruptedException e) {e.printStackTrace();}return "success";}}

運行效果

?

異步方法和調用方法一定要寫在不同的類中?,如果寫在一個類中,是沒有效果的！

?

?

?