假设以下方法在 .net 4 应用程序中被不同的线程调用了数千次。如何处理这种情况最好？请注意，瓶颈在于磁盘，但我希望 WriteFile() 方法能够快速返回。
数据可能高达几 MB。我们需要考虑线程池、TPL 或类似的方式吗？
public void WriteFile(string FileName, MemoryStream Data)
{
try
{
using (FileStream DiskFile = File.OpenWrite(FileName))
{
Data.WriteTo(DiskFile);
DiskFile.Flush();
DiskFile.Close();
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
}
您说文件无需按顺序或立即写入，最简单的方法是使用 Task：
private void WriteFileAsynchronously(string FileName, MemoryStream Data)
{
Task.Factory.StartNew(() => WriteFileSynchronously(FileName, Data));
}
private void WriteFileSynchronously(string FileName, MemoryStream Data)
{
try
{
using (FileStream DiskFile = File.OpenWrite(FileName))
{
Data.WriteTo(DiskFile);
DiskFile.Flush();
DiskFile.Close();
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
}
WriteFileASynchronous？ - 2i3rWriteFile 直接扔到 ConcurrentQueue 或类似结构中的生产者/消费者设计和单独服务于该队列的线程一起工作得很好...直到队列被填满。如果你要打开 50,000 个不同的文件，事情会很快堵塞。更不用说你的数据可能每个文件都有几兆字节，这会进一步限制队列的大小。WriteFile 方法附加到一个单独的文件上解决了问题。它写入的记录包括记录号、文件名、长度和数据。正如 Hans 在对你原始问题的评论中指出的那样，写入文件是快速的；打开文件是慢的。WriteFile 正在写入的文件。该线程读取每个记录头（编号、文件名、长度），打开一个新文件，然后将数据从日志文件复制到最终文件。Thread()中。然后，您可以“fire-and-forget”这些线程并返回到主调用线程。 foreach (file in filesArray)
{
try
{
System.Threading.Thread updateThread = new System.Threading.Thread(delegate()
{
WriteFileSynchronous(fileName, data);
});
updateThread.Start();
}
catch (Exception ex)
{
string errMsg = ex.Message;
Exception innerEx = ex.InnerException;
while (innerEx != null)
{
errMsg += "\n" + innerEx.Message;
innerEx = innerEx.InnerException;
}
errorMessages.Add(errMsg);
}
}