Joe*_*orn 3 .net c# concurrency file-io
以下代码只是一个简化的示例,用于演示我的问题:
using System;
using System.IO;
using System.Diagnostics;
using System.Threading;
namespace ConsoleApplication5
{
class Program
{
static string LogFile = @"C:\test.log";
static void Main(string[] args)
{
for (int i = 0;i<10;i++)
{
new Thread(new ParameterizedThreadStart(DoWork)).Start(i);
}
Console.ReadKey();
}
static void DoWork(object param)
{
int count = (int)param;
try
{
using (FileStream fs = new FileStream(LogFile, FileMode.Append, FileAccess.Write, FileShare.ReadWrite))
using (StreamWriter sw = new StreamWriter(fs))
{
sw.WriteLine(DateTime.Now + " - Start " + count.ToString());
Thread.Sleep(2000); // simulate doing some work
sw.WriteLine(DateTime.Now + " - End " + count.ToString());
}
}
catch (Exception e)
{
Console.WriteLine(count.ToString() + ": " + e.Message);
return;
}
Console.WriteLine(count.ToString() + ": Done.");
}
}
}
Run Code Online (Sandbox Code Playgroud)
这里的问题是,即使我调用该方法10次,通常也只有一个条目将其放入文件中。该文件应打开以允许共享。据我所知,没有抛出异常。这是怎么回事?
在此示例所遮盖的真实代码中,对DoWork的每次调用实际上是在一个单独的过程中,尽管测试表明结果是相同的-如果可以在此处进行修复,则可以在此处进行修复。
这里没有什么奇怪的事情。假设您有一个文件“ a.txt”,然后在记事本中打开了10次。之后,您更改文件的内容并将其保存在记事本的每个实例中。自然,您进行的最后一次保存是持久保存到文件中的,因为它会重写前9次保存。
我认为您在这里有相同的行为。因为在每个处理中都有一个Thread.Sleep,所以同时打开所有文件。因此,要保存的i文件将覆盖之前的保存(i-1)。
编辑:尝试删除Thread.Sleep(2000),您将在文件中拥有更多日志。