Spring@Async失败并拒绝执行异常

Question

我们需要并行运行任务，所以我们使用Spring@Async功能。为了提供执行器配置，我们正在创建一个执行器bean。

@Bean(name = "async")
    public Executor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(2);
        executor.setMaxPoolSize(2);
        executor.setQueueCapacity(5);
        executor.setThreadNamePrefix("MyExecutor-");
        executor.initialize();
        return executor;
    } 

一旦并行任务的数量超过maxpoolSize队列大小，下一个任务提交就会失败，并出现rejectedExecutionexception。

为了克服这一问题，我们从源html" target="_blank">代码研究了调用方中止策略：https://www.baeldung.com/java-rejectedexecutionhandler它提供了在队列和线程已满的情况下，主线程本身运行任务的功能。

设置需要：executor。setRejectedExecutionHandler（新的ThreadPoolExecutor.CallerRunPolicy（））；

Q1.我需要了解的是，ThreadPoolTaskExecator使用的是LinkedBlock队列，我的期望是，一旦最大池线程和队列大小已满并被占用，主线程将被阻塞，同时提交一个新任务，但相反，它是失败的拒绝例外，即使阻塞队列是目前在ThreadPoolTaskExec导师？

问题2。为了克服这一问题，我们如何实现一种阻塞机制，使main在提交新任务时不会失败，也不会自行运行（如executor.setRejectedExecutionHandler（new ThreadPoolExecutor.CallerRunPolicy（）），但会阻塞队列中的可用空间以将任务放入队列？

Answer 1

无限期地阻塞主线程可能会导致死锁情况。这就是为什么要为应用程序用户提供一个处理程序，以决定当线程池队列容量超过时应该采取什么行为。

正如下面的线程中所讨论的，可以实现所需阻塞行为的各种实现，但应该注意阻塞的时间和其他死锁场景。

队列已满时ThreadPoolExecutor块？