如何在多线程应用程序中执行文件日志记录

Question

我需要一种极速记录的方法（有关高速摄像机的帧信息）。 它只是我需要记录的几个数字和一个简单的 file.log。 事件记录会为此减慢速度。

然后我想，只需创建一个文件流，这样我就可以为我的应用程序锁定文件。并附加到它。

通常我会使用一个简单的行，例如

Filestream fs = new FileStream(@"D:\Log.csv", FileMode.Append, FileAccess.Write, FileShare.ReadWrite);

在方法内部。

但是，由于相机驱动程序的帧都是在一个新线程中执行的，所以我在这里遇到了问题。因为我不想在每次写入日志文件时重新打开和关闭文件。 （打开和关闭很慢）。

我想在我的程序开始时打开日志文件一次，线程应该只对其执行写入，而不是一次又一次地关闭和打开它。

如何实现这一点，因为这不起作用：

using System.IO;
FileStream fs = new FileStream(@"D:\Log.txt", FileMode.Append, FileAccess.Write, FileShare.ReadWrite);

    static void Main(string[] args)
    {
         // doing it in main doesn't work either.
         fs = new FileStream(@"D:\Log.txt", FileMode.Append, FileAccess.Write, FileShare.ReadWrite);
       //...
       //.. init camera and start camera lots of code follows but is not related to the question.
     }

     Camera_Thread.FrameArrived (FrameArrivedEventArgs e)
    {   
       byte[] n = MyFilterFunction(e.frame);         
       fs.WriteByte(MyArrayToString(n));
    }

Answer 1

有很多方法，但如果不是全部的话，大多数都涉及排队，尤其是在多线程环境中。

您可以使用 MSMQ 将日志排队等待处理，也可以使用单独的线程来处理内存队列中的日志。

string logFile = "Log.txt";
this.Queue = new ConcurrentQueue<string>();

var thread = new Thread(() => 
{
    string log;

    while (true)
    {
        while (!this.Queue.IsEmpty)
        {
            if (!this.Queue.TryDequeue(out log)) continue;

            File.AppendAllText(logFile, "\n" + log);
        }

        Thread.Sleep(1000);
    }

});

thread.Start();

这个实现没有考虑如何取消日志线程，所以我会让你先自己尝试。我还要补充一点，这不是很可靠，如果可以选择，我实际上会使用 MSMQ。