ReadDirectoryChangesW同步模式监控目录删除死锁问题求助

我太懂你这个糟心的问题了——用同步版的ReadDirectoryChangesW监控那种堆满文件的目录树时，一旦被监控的目录被删掉，整个监控线程直接卡成死锁，既检测不到目录没了，也没法正常退出。之前帮朋友排查过类似的情况，核心问题就是同步模式的API特性：它会一直阻塞着等变更通知，但目录被删除后，底层的文件系统句柄状态异常，API根本没法正常返回错误或者触发中断。

1. 切换到异步版ReadDirectoryChangesW调用 #

同步模式的阻塞特性就是这个死锁的根源，换成异步模式就能从根本上避免。看你的代码是Python类方法，用pywin32就能实现异步调用，绑定事件通知或者用IO完成端口，这样目录被删除时API会返回明确的错误码（比如ERROR_FILE_NOT_FOUND），你可以直接捕获并优雅退出监控。

给你一个简化的实现框架：

import win32file
import win32event
import win32api

def MonitorDirectory(self, out_queue):
    # 打开目录句柄，必须加FILE_FLAG_OVERLAPPED启用异步
    hDir = win32file.CreateFile(
        self.watch_path,
        win32file.FILE_LIST_DIRECTORY,
        # 一定要加FILE_SHARE_DELETE，否则其他进程删不了目录
        win32file.FILE_SHARE_READ | win32file.FILE_SHARE_WRITE | win32file.FILE_SHARE_DELETE,
        None,
        win32file.OPEN_EXISTING,
        win32file.FILE_FLAG_BACKUP_SEMANTICS | win32file.FILE_FLAG_OVERLAPPED,
        None
    )
    # 创建异步事件
    overlapped = win32file.OVERLAPPED()
    overlapped.hEvent = win32event.CreateEvent(None, 0, 0, None)
    
    try:
        while True:
            # 发起异步目录变更读取
            win32file.ReadDirectoryChangesW(
                hDir,
                4096,
                True,  # 监控子目录
                # 按需选择要监控的事件类型，减少负载
                win32file.FILE_NOTIFY_CHANGE_FILE_NAME | win32file.FILE_NOTIFY_CHANGE_DIR_NAME,
                overlapped,
                None
            )
            # 等待事件触发或1秒超时
            wait_result = win32event.WaitForSingleObject(overlapped.hEvent, 1000)
            
            if wait_result == win32event.WAIT_OBJECT_0:
                # 获取变更结果
                bytes_returned = win32file.GetOverlappedResult(hDir, overlapped, False)
                if bytes_returned > 0:
                    changes = win32file.FILE_NOTIFY_INFORMATION.FromBuffer(overlapped.getbuffer()[:bytes_returned])
                    # 将变更传入队列
                    out_queue.put(changes)
            elif wait_result == win32event.WAIT_TIMEOUT:
                # 超时后检查目录是否还存在
                try:
                    attr = win32api.GetFileAttributes(self.watch_path)
                    if not attr == win32file.FILE_ATTRIBUTE_DIRECTORY:
                        break  # 目录已不是有效目录，退出监控
                except:
                    # 目录不存在会抛出异常，直接退出
                    break
            else:
                # 发生未知错误，退出循环
                break
    except Exception as e:
        print(f"监控出错: {str(e)}")
    finally:
        # 清理资源
        win32file.CloseHandle(hDir)
        win32event.CloseHandle(overlapped.hEvent)

2. 给同步调用加超时与目录检查（应急方案） #

如果暂时不想改异步逻辑，也可以用线程+超时的方式包裹同步调用，避免无限阻塞。核心思路是把同步的ReadDirectoryChangesW放在子线程里，主线程定期等待并检查目录状态：

import win32file
import win32api
import threading

def MonitorDirectory(self, out_queue):
    hDir = win32file.CreateFile(
        self.watch_path,
        win32file.FILE_LIST_DIRECTORY,
        win32file.FILE_SHARE_READ | win32file.FILE_SHARE_WRITE | win32file.FILE_SHARE_DELETE,
        None,
        win32file.OPEN_EXISTING,
        win32file.FILE_FLAG_BACKUP_SEMANTICS,
        None
    )
    buffer = win32file.AllocateReadBuffer(4096)
    
    try:
        while True:
            changes = None
            error = None
            
            # 子线程执行同步读取
            def read_changes():
                nonlocal changes, error
                try:
                    changes = win32file.ReadDirectoryChangesW(
                        hDir,
                        buffer,
                        True,
                        win32file.FILE_NOTIFY_CHANGE_FILE_NAME | win32file.FILE_NOTIFY_CHANGE_DIR_NAME,
                        None,
                        None
                    )
                except Exception as e:
                    error = e
            
            read_thread = threading.Thread(target=read_changes)
            read_thread.start()
            # 等待1秒，超时则检查目录状态
            read_thread.join(1)
            
            if read_thread.is_alive():
                # 线程还在阻塞，检查目录是否存在
                try:
                    win32api.GetFileAttributes(self.watch_path)
                except:
                    # 目录不存在，关闭句柄终止线程
                    win32file.CloseHandle(hDir)
                    read_thread.join()
                    break
            else:
                if error:
                    # 读取出错，比如目录已删
                    break
                if changes:
                    out_queue.put(changes)
    finally:
        win32file.CloseHandle(hDir)

3. 几个必须注意的细节 #

• 一定要加FILE_SHARE_DELETE权限：如果没加这个权限，其他进程根本删不了你监控的目录，加了之后即使目录被删，你的句柄还能短暂保持有效，让你有机会检测到状态变化。
• 精简监控的事件类型：不要监控所有变更事件，只选你需要的（比如文件名、目录名变更），减少API的负载，避免大目录下的事件风暴。
• 兜底的目录检查：不管用同步还是异步模式，定期检查目录存在性都是必要的，这是防止死锁的最后一道防线。

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