ASP.NET Core跨线程快速删文件失败：文件被占用问题咨询

核心问题定位 #

从代码中可发现两个关键资源泄漏点，这是文件被占用无法立即删除的主要原因：

1. 未关闭的冗余FileStream：在treatItem方法中创建的Stream[] streams数组，既未被使用也未被释放，会持续持有文件句柄直到GC回收。
2. MyMultiStream未正确实现Dispose：自定义流继承自Stream但未重写Dispose(bool)方法，导致流被回收时，当前打开的curStream可能仍未释放文件句柄。

针对性修复方案 #

1. 清理冗余的FileStream创建逻辑 #

在treatItem方法中删除无用的流创建代码，因为MyMultiStream并未使用该参数：

private async Task<bool> treatItem(QueueItem Qitem, IRevisionIntegrationService ris) {
    await Task.Delay(0);
    L.LogWarning($"TryAddValue from P {Qitem.sessionId}");
    bool addOK = q.p.TryAdd(Qitem.sessionId, Qitem);
    if (!addOK) {
        L.LogError($"why couldnt we add session {Qitem.sessionId} to processing-queue?");
        return false; 
    }

    var startTime = DateTime.UtcNow;
    Guid revisionId = Qitem.revisionId; 

    string[] filePaths = getFilePaths(Qitem.sessionId);

    // 移除无用的流数组创建代码
    MyMultiStream multiStream = new MyMultiStream(filePaths, null, this.L, Qitem);
    BimRevisionStatus brs = await ris.UploadRevision(revisionId, multiStream, startTime);
    // 主动释放自定义流
    multiStream.Dispose();
    Qitem.status = brs;
    return true;
}

2. 为MyMultiStream实现正确的Dispose逻辑 #

重写Stream的Dispose方法，确保释放自定义流时，关闭并清理当前打开的文件流：

public class MyMultiStream : Stream {
    // ... 现有代码 ...

    protected override void Dispose(bool disposing) {
        if (disposing) {
            // 关闭并释放当前打开的文件流
            curStream?.Close();
            curStream?.Dispose();
            curStream = null;
            // 释放枚举器资源
            i?.Dispose();
        }
        base.Dispose(disposing);
    }
}

3. 优化文件写入的共享权限 #

在控制器写入文件时，指定允许读取、写入和删除的共享权限，避免后台线程操作被阻塞：

private async Task streamToChunkFile_WAB(string saveChunkPath) {
    using (MemoryStream ms = new MemoryStream()) {
        await Request.Body.CopyToAsync(ms);
        byte[] allBytes = ms.ToArray();
        // 写入时允许其他线程读取、写入和删除文件
        using (var fs = new FileStream(saveChunkPath, FileMode.Create, FileAccess.Write, FileShare.ReadWrite | FileShare.Delete)) {
            await fs.WriteAsync(allBytes, 0, allBytes.Length);
            await fs.FlushAsync(true); // 强制刷新数据到磁盘
        }
    }
}

替换原File.WriteAllBytesAsync，因为它默认共享权限为FileShare.Read，不允许删除操作。

4. 正确使用FileOptions.DeleteOnClose #

若要启用自动删除，需在打开文件时指定该选项，并确保所有打开该文件的流都被正确关闭：

private FileStream getNextStream() {
    string nextFileName = i.Current;
    if (nextFileName == null) { throw new Exception("getNextStream should not be called past file list"); }
    FileStream nextStream = new FileStream(
        path:nextFileName, 
        mode: FileMode.Open, 
        access: FileAccess.Read, 
        share: FileShare.ReadWrite| FileShare.Delete,
        bufferSize:4096,
        options: FileOptions.Asynchronous 
                | FileOptions.SequentialScan
                | FileOptions.DeleteOnClose
    );
    log.LogWarning($"TELLUS making new stream [{nextFileName}] opened:[{++openStreamCounter}] closed:[{closedStreamCounter}]");

    curFileName = nextFileName;
    ++qItem.chunkCount;
    return nextStream;
}

启用该选项后，当curStream关闭并释放，系统会自动删除文件，无需手动调用删除方法。

辅助建议 #

• 调试时主动触发GC：删除文件前可临时调用GC.Collect(); GC.WaitForPendingFinalizers();验证资源释放效果，但生产环境不建议频繁使用。
• 文件句柄检测：使用Process Explorer等工具查看持有文件句柄的进程/线程，确认修复效果。

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