Python中线程的暂停、恢复与停止实现问题求助

首先明确：你当前的Lock方案完全无法实现需求。核心原因是目标线程的回调函数里没有尝试获取MYLOCK，调用stop()或sleep_for()时的锁操作，根本不会对回调的执行产生任何干扰——线程会继续不受控地运行，完全达不到停止或休眠的效果。

由于你无法修改用户传入的回调函数，无法通过标志位、事件等协作方式控制线程，结合Python线程的特性（官方不支持安全强制终止线程，强制终止易引发资源泄漏、死锁等问题），使用多进程（multiprocessing）替代线程是最可行的方案，进程支持安全的强制终止，且无需回调函数做任何配合。

基于multiprocessing的实现代码 #

import multiprocessing
import threading
import os
from signal import SIGSTOP, SIGCONT

# 匹配原模块的时间单位定义
MSEC = 0.001

class Thread:
    def __init__(self, callback, *args):
        self.process = multiprocessing.Process(target=callback, args=args)
        self.process.start()  # 初始化时启动进程，匹配原模块行为
        
    def stop(self):
        # 强制终止进程并回收资源
        if self.process.is_alive():
            self.process.terminate()
            self.process.join()
            
    def sleep_for(self, duration, units=MSEC):
        if not self.process.is_alive():
            return
        # 发送SIGSTOP信号暂停进程
        os.kill(self.process.pid, SIGSTOP)
        # 定时发送SIGCONT信号恢复进程
        threading.Timer(duration * units, lambda: os.kill(self.process.pid, SIGCONT)).start()

跨平台兼容处理（Windows系统） #

上述代码依赖Unix/Linux的信号机制，Windows系统不支持SIGSTOP/SIGCONT，可通过pywin32库实现进程的暂停与恢复：

import multiprocessing
import threading
import win32api
import win32process

MSEC = 0.001

class Thread:
    def __init__(self, callback, *args):
        self.process = multiprocessing.Process(target=callback, args=args)
        self.process.start()
        
    def stop(self):
        if self.process.is_alive():
            self.process.terminate()
            self.process.join()
            
    def sleep_for(self, duration, units=MSEC):
        if not self.process.is_alive():
            return
        # 获取进程句柄并暂停
        handle = win32api.OpenProcess(win32process.PROCESS_SUSPEND_RESUME, False, self.process.pid)
        win32process.SuspendThread(handle)
        
        # 定时恢复进程并关闭句柄
        def resume_process():
            win32process.ResumeThread(handle)
            win32api.CloseHandle(handle)
            
        threading.Timer(duration * units, resume_process).start()

为什么不推荐线程强制终止？ #

Python的threading模块没有提供安全的强制终止线程的方法，因为线程共享进程内存空间，强制终止可能导致：

• 持有的锁无法释放，引发死锁
• 打开的文件、网络连接无法正常关闭
• 内存泄漏或数据损坏

因此在无法修改回调函数的前提下，多进程是更可靠的选择。

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