package com.xuyijie.threadpooldemo.config;

import org.springframework.boot.SpringBootConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.*;

/**
 * @author 徐一杰
 * @date 2022/9/20 13:05
 * @description 配置線(xiàn)程池
 */
@SpringBootConfiguration
@EnableAsync
public class ThreadPoolConfig {

    @Bean
    public ExecutorService getThreadPool(){
        ExecutorService threadPool = new ThreadPoolExecutor(2,5,
                1L, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(3),
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.AbortPolicy());
        return threadPool;
//        return Executors.newCachedThreadPool();
    }

    /**
     * 下面的配置是配置Springboot的@Async注解所用的線(xiàn)程池
     */
    @Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //獲取到cpu內(nèi)核數(shù)
        int i = Runtime.getRuntime().availableProcessors();
        // 設(shè)置線(xiàn)程池核心容量
        executor.setCorePoolSize(i);
        // 設(shè)置線(xiàn)程池最大容量
        executor.setMaxPoolSize(i * 2);
        // 設(shè)置任務(wù)隊(duì)列長(zhǎng)度
        executor.setQueueCapacity(200);
        // 設(shè)置線(xiàn)程超時(shí)時(shí)間
        executor.setKeepAliveSeconds(60);
        // 設(shè)置線(xiàn)程名稱(chēng)前綴
        executor.setThreadNamePrefix("xyjAsyncPool-");
        // 設(shè)置任務(wù)丟棄后的處理策略,當(dāng)poolSize已達(dá)到maxPoolSize，如何處理新任務(wù)（是拒絕還是交由其它線(xiàn)程處理）,CallerRunsPolicy：不在新線(xiàn)程中執(zhí)行任務(wù)，而是由調(diào)用者所在的線(xiàn)程來(lái)執(zhí)
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }

}

executorService.execute(() -> {
?try {
String message = redisUtil.listRightPop(“queue:queueData”, 5, TimeUnit.SECONDS);
System.out.println(“接收到了消息message” + message);
} catch (Exception ex) {
date.set(simpleDateFormat.format(new Date()));
System.out.println(“隊(duì)列阻塞超時(shí)-” + date + ex.getMessage());
} finally {
?date.set(simpleDateFormat.format(new Date()));
System.out.println(“線(xiàn)程銷(xiāo)毀-” + date);
executorService.shutdown();
}
?});

package com.xuyijie.threadpooldemo.controller;

import com.xuyijie.threadpooldemo.async.AsyncMethod;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.ExecutorService;

/**
 * @author 徐一杰
 * @date 2022/9/20 10:30
 * @description
 */
@RestController
@RequestMapping("/test")
public class TestController {

    @Autowired
    private ExecutorService executorService;
    @Autowired
    private AsyncMethod asyncMethod;
    
    @GetMapping("/helloThread")
    public void helloThread(){
        executorService.execute(() -> {
            for (int i = 0;i < 100;i++){
                System.out.println("111");
            }
        });
        executorService.execute(() -> {
            for (int i = 0;i < 100;i++){
                System.out.println("222");
            }
        });
    }
	
	@GetMapping("/helloAsync")
    public String helloAsync(){
    	// 這個(gè)方法是異步的
        asyncMethod.print();
        System.out.println("print方法還在循環(huán)，但我已經(jīng)可以執(zhí)行了");
        return "print方法還在循環(huán)，但我已經(jīng)可以執(zhí)行了";
    }

}

package com.xuyijie.threadpooldemo.async;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * @author 徐一杰
 * @date 2022/9/20 15:10
 * @description 異步方法
 */
@Component
public class AsyncMethod {

	/**
     * 異步方法，如果@Async加在類(lèi)的上面，則整個(gè)類(lèi)中的方法都是異步的
     */
    @Async
    public void print(){
        for (int i = 0;i < 100;i++){
            System.out.println(i);
        }
    }
}