@Configuration
@EnableAsync // 開啟Spring異步支持
public class AsyncConfig {
    /**
     * 自定義異步線程池配置
     * @return 線程池執(zhí)行器
     */
    @Bean("taskExecutor") // 自定義線程池名稱，便于指定使用
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(4); // 核心線程數(shù)，默認(rèn)建議設(shè)置為CPU核心數(shù)
        executor.setMaxPoolSize(8); // 最大線程數(shù)，建議為核心線程數(shù)的2倍，應(yīng)對(duì)突發(fā)高并發(fā)
        executor.setQueueCapacity(100); // 任務(wù)隊(duì)列容量，緩沖待執(zhí)行任務(wù)
        executor.setThreadNamePrefix("Async-"); // 線程名稱前綴，便于日志排查
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 拒絕策略：主線程執(zhí)行
        executor.initialize(); // 初始化線程池
        return executor;
    }
}

@Service
public class DemoService {

    @Async("taskExecutor") // 指定使用自定義的線程池
    public void sendEmail(String email) {
        System.out.println("線程:" + Thread.currentThread().getName() + "消息ID:" +" 正在發(fā)送郵件至:" + email);
    }
}

@Service
public class DemoService {

    // 注入自定義線程池（對(duì)應(yīng)AsyncConfig中配置的bean）
    @Resource(name = "taskExecutor")
    private ThreadPoolTaskExecutor executor;

    /**
     * 異步生成業(yè)務(wù)報(bào)表
     */
    public void generateReport() {
        for (int i = 0; i < 50; i++) {
            // 提交異步任務(wù)到線程池
            executor.execute(() -> {
                System.out.println("線程：" + Thread.currentThread().getName() + " 正在生成報(bào)表");
                // 報(bào)表生成核心邏輯（數(shù)據(jù)查詢、計(jì)算、導(dǎo)出等）
            });
        }
    }
}

@Service
public class DemoService {
    
    @Resource(name = "taskExecutor")
	private ThreadPoolTaskExecutor executor;

    /**
     * 異步檢查庫(kù)存
     * @return 庫(kù)存是否充足（Future結(jié)果）
     */
    public CompletableFuture<Boolean> checkInventory() {
        // 異步執(zhí)行庫(kù)存檢查邏輯
        return CompletableFuture.supplyAsync(() -> {
            System.out.println("線程：" + Thread.currentThread().getName() + " 檢查庫(kù)存");
            return true; // 模擬庫(kù)存充足
        },executor);
    }

    /**
     * 異步扣減余額
     * @return 余額扣減是否成功（Future結(jié)果）
     */
    public CompletableFuture<Boolean> deductBalance() {
        return CompletableFuture.supplyAsync(() -> {
            System.out.println("線程：" + Thread.currentThread().getName() + " 扣減余額");
            return true; // 模擬扣減成功
        },executor);
    }

    /**
     * 下單核心邏輯：并行執(zhí)行庫(kù)存檢查+余額扣減，完成后執(zhí)行后續(xù)操作
     */
    public void placeOrder() {
        // 并行執(zhí)行多個(gè)異步任務(wù)
        CompletableFuture.allOf(checkInventory(), deductBalance())
                .thenRun(() -> { // 所有任務(wù)完成后執(zhí)行
                    System.out.println("線程：" + Thread.currentThread().getName() + " 所有前置校驗(yàn)完成，開始創(chuàng)建訂單");
                    // 訂單創(chuàng)建核心邏輯
                });
    }
}

/**
 * 訂單創(chuàng)建事件
 */
public class OrderCreatedEvent extends ApplicationEvent {
    private Long orderId; // 訂單ID

    /**
     * 構(gòu)造函數(shù)
     * @param source 事件源（當(dāng)前發(fā)布事件的對(duì)象）
     * @param orderId 訂單ID
     */
    public OrderCreatedEvent(Object source, Long orderId) {
        super(source);
        this.orderId = orderId;
    }

    // getter
    public Long getOrderId() {
        return orderId;
    }
}

@Service
public class DemoService {

    // 注入Spring事件發(fā)布器
    @Resource
    private ApplicationEventPublisher publisher;

    /**
     * 創(chuàng)建訂單（核心邏輯）
     */
    public void createOrder() {
        // 1. 執(zhí)行創(chuàng)建訂單的核心邏輯
        Long orderId = 123L; // 模擬生成訂單ID
        System.out.println("主線程：創(chuàng)建訂單，訂單ID：" + orderId);

        // 2. 發(fā)布訂單創(chuàng)建事件
        publisher.publishEvent(new OrderCreatedEvent(this, orderId));
    }
}

@Component
public class OrderListener {
    /**
     * 異步處理訂單創(chuàng)建事件
     * @param event 訂單創(chuàng)建事件
     */
    @Async("taskExecutor") // 異步處理，指定自定義線程池
    @EventListener // 監(jiān)聽OrderCreatedEvent事件
    public void handleOrderCreatedEvent(OrderCreatedEvent event) {
        Long orderId = event.getOrderId();
        System.out.println("線程：" + Thread.currentThread().getName() + " 處理訂單事件，訂單ID：" + orderId);
        // 事件處理邏輯（如：發(fā)送訂單通知、更新庫(kù)存、記錄日志等）
    }
}

@Service
public class DemoService {

    // 創(chuàng)建固定大小的JDK原生線程池（10個(gè)核心線程）
    private ExecutorService executor1 = Executors.newFixedThreadPool(10, r -> {
        Thread thread = new Thread(r);
        thread.setName("JdkAsync-"); // 線程名稱前綴
        return thread;
    });

    /**
     * 異步處理數(shù)據(jù)
     */
    public void processData() {
        // 提交任務(wù)到線程池執(zhí)行
        executor1.submit(() -> {
            System.out.println("線程：" + Thread.currentThread().getName() + " 正在處理數(shù)據(jù)");
            // 數(shù)據(jù)處理核心邏輯
        });
    }
}

@Configuration
@EnableAsync // 開啟異步支持
@EnableScheduling // 開啟定時(shí)任務(wù)支持
public class ScheduledConfig {
    /**
     * 異步定時(shí)執(zhí)行報(bào)表統(tǒng)計(jì)任務(wù)
     * fixedRate = 5000：每隔5秒執(zhí)行一次（從上一次執(zhí)行開始計(jì)時(shí)）
     */
    @Async("taskExecutor") // 異步執(zhí)行，指定自定義線程池
    @Scheduled(fixedRate = 5000)
    public void reportJob() {
        System.out.println("線程：" + Thread.currentThread().getName() + " 執(zhí)行定時(shí)報(bào)表統(tǒng)計(jì)，時(shí)間：" + System.currentTimeMillis());
        // 周期性數(shù)據(jù)處理邏輯（如：統(tǒng)計(jì)昨日訂單、清理無(wú)效數(shù)據(jù)、同步第三方數(shù)據(jù)等）
    }
}