concurrent.futures怎么终止他的一个执行进程

在 `concurrent.futures` 中，如果你想要终止一个正在进行的进程，通常有两种方法：通过 Future 对象的 cancel() 方法或通过 ProcessPoolExecutor 的 shutdown() 方法。这里分别解释一下这两种情况：

1. **使用 cancel() 方法**：
- 对于 `ThreadPoolExecutor`，如果你想尝试取消一个 Future 对象的任务，可以这样做：

     def cancelable_task():
         while True:
             pass  # 这是一个无限循环，为了展示如何取消

     with concurrent.futures.ThreadPoolExecutor() as executor:
         future = executor.submit(cancelable_task)
         
         if not future.running():  # 确保任务尚未开始
             future.cancel()  # 取消任务

         try:
             future.result(timeout=0.1)  # 防止阻塞
         except concurrent.futures.CancelledError:
             print("Task cancelled")

- `cancel()` 方法不会立即停止正在执行的任务，它会设置一个标志通知任务将来会被取消，所以你需要捕获 `CancelledError`。

2. **使用 shutdown() 方法**：
- 对于 `ThreadPoolExecutor` 或 `ProcessPoolExecutor`，当你不再需要执行更多任务时，可以调用 shutdown() 方法，它可以有三个可选参数来控制行为：

     executor.shutdown(wait=True, cancel_futures=True, timeout=None)

- `wait=True` 会让所有已提交的任务完成（包括那些已经运行的）。
- `cancel_futures=True` 会取消所有剩余的未完成的 futures。
- `timeout=None` 如果设置一个非零值，那么等待过程将在此时后取消，所有剩余的任务将被取消。

记住，一旦调用了 `shutdown()` 或 `cancel()`，你应该避免继续向 executor 添加新的任务，因为它们可能会失败或不确定的行为。