SpringBoot中实现多线程6种方式总结

@Configuration
@EnableAsync
public class AsyncConfig {
    @Bean("taskExecutor")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(4);
        executor.setMaxPoolSize(8);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("Async-");
        executor.initialize();
        return executor;
    }
}

@Service
public class UserService {
    @Async("taskExecutor")
    public void sendEmail(String email) {
        // 耗时操作
    }
}

@Service
public class ReportService {
    @Autowired
    private ThreadPoolTaskExecutor executor;

    public void generateReport() {
        executor.execute(() -> {
            // 处理复杂报表生成
        });
    }
}

@Service
public class OrderService {
    @Async
    public CompletableFuture<Boolean> checkInventory() {
        return CompletableFuture.completedFuture(true);
    }

    public void placeOrder() {
        CompletableFuture.allOf(
            checkInventory(),
            deductBalance()
        ).thenRun(() -> {
            // 所有前置任务完成后执行
        });
    }
}

public class OrderCreatedEvent extends ApplicationEvent {
    public OrderCreatedEvent(Object source, Long orderId) {
        super(source);
        this.orderId = orderId;
    }
}

@Service
public class OrderService {
    @Autowired
    private ApplicationEventPublisher publisher;

    public void createOrder() {
        publisher.publishEvent(new OrderCreatedEvent(this, 123L));
    }
}

@Component
public class OrderListener {
    @Async
    @EventListener
    public void handleEvent(OrderCreatedEvent event) {
        // 处理后续逻辑
    }
}

@Service
public class DataService {
    private ExecutorService executor = Executors.newFixedThreadPool(10);

    public void processData() {
        executor.submit(() -> {
            // 执行耗时操作
        });
    }
}

@Configuration
@EnableAsync
@EnableScheduling
public class ScheduledConfig {
    @Async
    @Scheduled(fixedRate = 5000)
    public void reportJob() {
        // 定时执行异步任务
    }
}