如何在Python中实现可取消的带返回值线程外函数？

要实现可随时取消、还能拿到返回值的输入函数，用线程行不通——因为input()是阻塞调用，Python线程没法强制终止阻塞中的线程，所以必须用多进程来做。你提到的Process和Pool的问题，可以用Process+Queue结合的方式解决：用Process来运行输入逻辑（支持终止），用Queue来传递输入结果（实现返回值获取）。

具体实现代码 #

from multiprocessing import Process, Queue
import time

def input_worker(prompt, result_queue):
    # 运行输入逻辑，把结果放进队列
    user_input = input(prompt)
    result_queue.put(user_input)

def cancel_process(target_process, delay):
    # 模拟延迟取消的逻辑
    time.sleep(delay)
    if target_process.is_alive():
        print("\n输入已超时，取消输入")
        target_process.terminate()
        target_process.join()

if __name__ == "__main__":
    result_queue = Queue()
    # 创建输入进程
    input_proc = Process(target=input_worker, args=("请输入你的名字：", result_queue))
    # 创建取消进程（也可以用线程，这里用进程只是示例）
    cancel_proc = Process(target=cancel_process, args=(input_proc, 5))  # 5秒后取消

    input_proc.start()
    cancel_proc.start()

    # 等待输入进程结束
    input_proc.join()

    # 尝试从队列获取结果
    if not result_queue.empty():
        user_name = result_queue.get()
        print(f"你输入的名字是：{user_name}")
    else:
        print("没有获取到输入内容")

代码说明 #

• input_worker函数：作为进程的执行目标，负责调用input()并把结果存入Queue，队列是多进程安全的通信方式。
• cancel_process函数：模拟超时取消逻辑，延迟指定时间后，如果输入进程还在运行，就调用terminate()终止它，再用join()回收资源。
• 主进程中：通过Queue判断是否有输入结果——如果输入在取消前完成，队列里就有值；如果被取消，队列是空的。

补充说明 #

• 如果你想用线程来做取消逻辑（不需要额外进程），把cancel_process改成线程也可以，因为它只是做延迟和调用进程的终止方法，线程执行这个逻辑完全没问题。
• 注意必须在if __name__ == "__main__":下启动多进程，这是Windows系统下多进程的要求，Linux/macOS也兼容。

内容的提问来源于stack exchange，提问作者Markas M