如何使控制台应用中的FileSystemWatcher事件在STA线程中运行？

针对FileSystemWatcher事件线程与STA线程要求的冲突问题，有两种实用解决思路：

思路1：在事件回调中启动独立STA线程处理上传 #

FileSystemWatcher的事件触发线程默认为MTA，你可以在OnCreated事件里手动创建一个STA线程，将文件上传逻辑放在该线程中执行：

private static void OnFileCreated(object sender, FileSystemEventArgs e)
{
    // 短暂延迟避免文件未写入完成就处理，也可替换为重试逻辑
    Thread.Sleep(100);

    var uploadThread = new Thread(() =>
    {
        try
        {
            // 调用你的专有文件上传方法
            UploadFileToDatabase(e.FullPath);
        }
        catch (Exception ex)
        {
            Console.WriteLine($"文件上传失败：{ex.Message}");
        }
    });
    // 设置线程为STA模式
    uploadThread.SetApartmentState(ApartmentState.STA);
    uploadThread.Start();
}

思路2：将事件任务同步到STA主线程处理 #

如果希望所有上传逻辑统一在主线程执行，可先将主线程设为STA，再通过线程安全队列传递待处理文件路径，主线程循环处理队列任务：

第一步：配置主线程为STA #

在Main方法上添加[STAThread]特性，确保主线程以STA模式运行：

[STAThread]
static void Main(string[] args)
{
    // 初始化线程安全的阻塞队列，用于传递待处理文件路径
    var pendingFiles = new BlockingCollection<string>();

    // 初始化并启动FileSystemWatcher
    var watcher = new FileSystemWatcher(@"C:\Your\Target\Directory");
    watcher.Created += (sender, e) =>
    {
        Thread.Sleep(100);
        pendingFiles.Add(e.FullPath);
    };
    watcher.EnableRaisingEvents = true;

    Console.WriteLine("目录监控已启动，按Ctrl+C退出...");

    // 主线程循环处理队列中的文件
    foreach (var filePath in pendingFiles.GetConsumingEnumerable())
    {
        try
        {
            UploadFileToDatabase(filePath);
        }
        catch (Exception ex)
        {
            Console.WriteLine($"处理文件 {filePath} 失败：{ex.Message}");
        }
    }
}

关键说明 #

• 控制台程序默认主线程为MTA，必须通过[STAThread]特性或Thread.CurrentThread.SetApartmentState(ApartmentState.STA);（需在主线程启动后立即执行）切换为STA。
• BlockingCollection自带线程安全特性，主线程的GetConsumingEnumerable()会持续阻塞等待新任务，无需手动处理线程同步。

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