使用Linux inotify开发Rust文件同步器的并发一致性问题咨询

场景与需求 #

我正在用Rust开发一款简易文件同步器，基于Linux的inotify工具实现本地文件变更监控。核心需求是：当检测到新文件或目录创建时，通过inotify_add_watch系统调用给已有的inotify实例动态添加新监听，且添加操作可能在多线程中执行，同时监听线程需要持续阻塞等待文件变更事件。

核心疑问 #

针对多线程操作inotify实例的场景，我有两个安全性疑问：

• 一个线程调用inotify.read_events_blocking()阻塞读取事件时，另一个线程调用inotify.watches().add()添加新监听，是否会产生冲突？
• 多个线程同时调用watches().add()给不同文件添加监听，是否存在一致性问题？

查阅Linux官方手册，仅说明这些操作通过inotify实例的文件描述符完成，但未明确提及多线程下的安全性。我编写了如下实验代码验证第一种场景，运行过程未出现异常，但仍无法确定其安全性：

fn main() {
    let mut inotify = Inotify::init().unwrap();
    std::thread::spawn(move || {
        let mut buffer = [0; 1024];
        loop {
            let events = inotify.read_events_blocking(buffer.as_mut()).unwrap();
            for event in events {
                println!("{:?}", event);
            }
        }
    });
    loop {
        // 输入文件路径以添加监听
        let mut file_path = String::new();
        std::io::stdin().read_line(&mut file_path).unwrap();
        let file_path = file_path.trim();
        inotify.watches().add(file_path, *WATCH_EVENTS).unwrap();
        println!("watching {}", file_path);
    }
}

版本兼容问题 #

除了安全性疑问，还遇到了库版本的限制：read_events_blocking方法需要inotify实例的可变引用，而用于添加监听的Watches结构体在inotify库0.10.0版本中是私有的，无法跨线程传递使用：

// read_events_blocking 方法签名
pub fn read_events_blocking<'a>(&mut self, buffer: &'a mut [u8])

// watches 方法签名
pub fn watches(&self) -> Watches {
    Watches::new(self.fd.clone())
}

更新补充 #

inotify库的0.10.2版本已将Watches结构体公开，基于此我推测多线程下动态添加监听的操作是安全的，但仍需要权威的安全性确认。

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