c# - 无法使用线程写入文件

Question

我正在编写一个重复执行任务的 Windows 服务 (C#)。我正在使用线程来完成我的要求。现在我需要维护一个日志文件，用于保存有关操作的日志。

我的服务类如下

public partial class CPEService : ServiceBase
{
    static ServiceBot bot = new ServiceBot();
    static ProgramLog logger = new ProgramLog();//ProgramLog Object

    private static bool state = true;

    //private static int count = 1;
    //private System.Timers.Timer timer;
    public CPEService()
    {
        InitializeComponent();
    }
            internal void TestStartupAndStop()
    {
        Thread workerThread = new Thread(loopTrough);
        workerThread.Start();
    }

    protected override void OnStart(string[] args)
    {
        Thread workerThread = new Thread(loopTrough);
        workerThread.Start(); 
    }

    private void loopTrough()
    {
        logger.log("Thread fired");
        while (state)
        {
            logger.log("Thread fired"); //This is not Working
            bot.start();
            Thread.Sleep(180000);
        }
    }

    protected override void OnStop()
    {
        state = false;
    }


}

我有一个单独的类调用“ProgramLog”来处理所有与日志相关的操作。这就是那个类。

 public class ProgramLog
{
    string fileName = "";//Global variable to store file name

    #region method to handle usual log records
    public void log(string text)//create normal Log text
    {
        fileName = "Log\\" + DateTime.Now.Date.ToString("d").Replace('/', '_') + ".txt";
        if (File.Exists(AppDomain.CurrentDomain.BaseDirectory+fileName))
        {
            using (FileStream fs = new FileStream(AppDomain.CurrentDomain.BaseDirectory + fileName, FileMode.Append))
            using (TextWriter tw = new StreamWriter(fs))
            {
                tw.WriteLine(text);
                tw.Flush();
                tw.Close();
                fs.Close();
            }
        }
        else
        {
            createFolder();
            log(text);
        }
    }
    #endregion

    #region log Error record 
    public void logError(string text, string className,int LineNumber, string Stacktrace)//create error text
    {
        fileName = "Log\\" + DateTime.Now.Date.ToString("d").Replace('/', '_') + ".txt";
        if (File.Exists(AppDomain.CurrentDomain.BaseDirectory + fileName))
        {
            using (FileStream fs = new FileStream(AppDomain.CurrentDomain.BaseDirectory + fileName, FileMode.Append))
            using (TextWriter tw = new StreamWriter(fs))
            {
                tw.WriteLine("**************************ERROR****************************");
                tw.WriteLine(text);
                tw.WriteLine("In Class :{0}", className);
                tw.WriteLine("In Line :{0}", LineNumber);
                tw.WriteLine("ERROR :{0}",Stacktrace);
                tw.WriteLine("***********************************************************");
            }
        }
        else
        {
            createFolder();
            logError(text,className,LineNumber,Stacktrace);
        }
    }
    #endregion

    #region create folder to store log files
    public void createFolder()//create a folder for Log files
    {
        try
        {
            if (!Directory.Exists(AppDomain.CurrentDomain.BaseDirectory + "Log"))
            {
                string folderName = "Log";
                Directory.CreateDirectory(AppDomain.CurrentDomain.BaseDirectory + folderName);
                FileStream fs = new FileStream(AppDomain.CurrentDomain.BaseDirectory + fileName, FileMode.Create);
                StreamWriter sr = new StreamWriter(fs);
                sr.Flush();
                sr.Close();
                fs.Close();
            }
            else
            {
                FileStream fs = new FileStream(AppDomain.CurrentDomain.BaseDirectory + fileName, FileMode.Create);
                StreamWriter sr = new StreamWriter(fs);
                sr.Flush();
                sr.Close();
                fs.Close(); 
            }
        }
        catch (Exception e)
        {
            Console.WriteLine(e.StackTrace);
        }
    }
    #endregion
} 

根据上面的类，当我启动服务时，它需要在它不存在的地方创建名为“Log”的文件夹，然后在该文件夹中创建一个文本文件，最后开始创建日志条目。

即使线程正常工作，它也不会触及“ProgramLog”方法。我通过直接调用方法“loopTrough”来检查。然后它工作正常。

请帮我解决这个错误。

谢谢

Answer 1

你声明了一个Thread workerThread = new Thread(loopTrough);，但是你没有启动这个Thread。只需调用 workerThread.Start()。