线程池的拒绝策略是在任务无法被接受执行时,线程池采取的一种处理方式。Java中的ThreadPoolExecutor提供了几种内置的拒绝策略,可以通过构造函数或setRejectedExecutionHandler方法进行设置。以下是常见的拒绝策略:
AbortPolicy(默认策略):
AbortPolicy是默认的拒绝策略,当任务无法被接受时,会抛出RejectedExecutionException异常。这是默认的策略,表明线程池已经饱和,不能接受新的任务。
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
2.CallerRunsPolicy:
CallerRunsPolicy策略会将被拒绝的任务交给提交任务的线程来执行。这种策略不会抛出异常,而是将任务回退给调用者,由调用者自行处理。
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
3.DiscardPolicy:
DiscardPolicy策略会默默地丢弃无法处理的任务,不抛出异常,也不做任何处理。对于一些不太重要的任务,使用这个策略可能是一种合理的选择
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
4.DiscardOldestPolicy:
DiscardOldestPolicy策略会丢弃队列中最老的一个任务,然后尝试重新提交当前任务。
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
自定义拒绝策略也是可能的,只需实现RejectedExecutionHandler接口并提供相应的处理逻辑。例如:
public class CustomRejectedExecutionHandler implements RejectedExecutionHandler {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
// 自定义处理逻辑
// ...
}
}
// 使用自定义的拒绝策略
executor.setRejectedExecutionHandler(new CustomRejectedExecutionHandler());
选择合适的拒绝策略取决于应用程序的需求和性质。不同的策略适用于不同的场景,开发人员应根据实际情况进行选择。
原文链接:https://blog.csdn.net/NZC2237/article/details/135560277