java - 在 Java 中是否有更简单的方法来知道被拒绝的任务(由执行器)是否已作为 "CallerRunsPolicy"运行？

Question

我正在使用 Spring，并且我已经使用 CallerRunsPolicy 设置了一个 ThreadPoolTask​​Executor(用于频繁运行类似且重复的任务)。由于我正在构建的功能的性质，我可能会生成许多任务并需要异步运行。

由于队列已超出其容量，这些任务将在调用者的线程中运行。我需要一种方法来查找哪些任务在调用者的线程中运行。我知道，在运行时，我可以调用执行器上的方法来确定队列是否已满，然后任何新任务都将遵循 CallersRunPolicy，但我想知道是否还有其他方法可以做到这一点？

Answer 1

定义您自己的RejectedExecutionHandler并将其传递到下面的构造函数中。

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long 
keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, 
ThreadFactory threadFactory, RejectedExecutionHandler handler)

MyRejectedExecutionHandler的示例代码

public class MyRejectedExecutionHandler extends CallerRunsPolicy{
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
        // Add your code to log Runnable details.
        super.rejectedExecution(r, executor);
    }

}