ThreadPoolExecutor.AbortPolicy()
时间: 2024-01-30 11:12:25 浏览: 113
ThreadPoolExecutor.AbortPolicy是ThreadPoolExecutor的默认RejectedExecutionHandler实现类之一。当线程池无法接受新的任务时,该策略会抛出RejectedExecutionException异常,以通知调用者任务被拒绝执行。
以下是一个使用ThreadPoolExecutor.AbortPolicy的示例:
```python
from concurrent.futures import ThreadPoolExecutor
def task():
print("Executing task")
executor = ThreadPoolExecutor(max_workers=1, thread_name_prefix="MyThread",
rejected_execution_handler=ThreadPoolExecutor.AbortPolicy())
# 提交任务
executor.submit(task)
# 再次提交任务,由于线程池已满,将抛出RejectedExecutionException异常
executor.submit(task)
```
在上述示例中,我们创建了一个最大工作线程数为1的ThreadPoolExecutor,并将RejectedExecutionHandler设置为ThreadPoolExecutor.AbortPolicy。首先,我们提交了一个任务,该任务会被执行。然后,我们再次提交一个任务,由于线程池已满,该任务将被拒绝执行并抛出RejectedExecutionException异常。
阅读全文