在Spring boot中使用两个执行器来运行并行作业

# 第一个线程池
spring.task.execution.pool.core-size=10
spring.task.execution.pool.max-size=20
spring.task.execution.pool.queue-capacity=100

# 第二个线程池
spring.task.execution.pool2.core-size=5
spring.task.execution.pool2.max-size=10
spring.task.execution.pool2.queue-capacity=50

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class ParallelJobService {

    @Autowired
    @Qualifier("taskExecutor")
    private ThreadPoolTaskExecutor taskExecutor;

    @Autowired
    @Qualifier("taskExecutor2")
    private ThreadPoolTaskExecutor taskExecutor2;

    @Async("taskExecutor")
    public void runJob1() {
        // 执行作业1的逻辑
    }

    @Async("taskExecutor2")
    public void runJob2() {
        // 执行作业2的逻辑
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

@Component
public class MyCommandLineRunner implements CommandLineRunner {

    @Autowired
    private ParallelJobService parallelJobService;

    @Override
    public void run(String... args) throws Exception {
        parallelJobService.runJob1();
        parallelJobService.runJob2();
    }
}