如何在c#.net中将此单线程修改为多线程[关闭]

Question

您好，我在 c#.net 中使用单线程，如果假设作业 A 在一个很长的过程中运行，直到作业 A 完成，否则我将向您解释它现在是如何工作的，除非作业 A 完成它不会去作业 B，但是在这里要求是所有的工作都应该被激活，但没有一个工作被打断，所以我该如何修改这个线程，任何人都可以尽快给出一些建议

protected override void OnStart(string[] args)
{
    strNowDate = DateTime.Now.ToLongTimeString();
    timerjob.Elapsed += new ElapsedEventHandler(CsvGenFromDatabase);
    timerjob.Interval = Convert.ToDouble(DueTime);
    timerjob.Enabled = true;
    eventLog1.WriteEntry("my service started");
}
protected override void OnStop()
{
    strNowDate = DateTime.Now.ToLongTimeString();
    eventLog1.WriteEntry("my service stopped");
}
private void CsvGenFromDatabase(object sender, EventArgs e)
{
    timerjob.stop();
    using (TransactionScope scope = new TransactionScope(TransactionScopeOption.RequiresNew)) // Transaction Scope Started  
    {
        Thread threadITD = new Thread(new ThreadStart(FileGenerationForITD));  // Thread Initialize for ITD
        Thread threadCTD = new Thread(new ThreadStart(FileGenerationForCTD));  // Thread Initialize for CTD
        Thread threadCID = new Thread(new ThreadStart(FileGenerationForCID));  // Thread Initialize for CID
        Thread threadFFM = new Thread(new ThreadStart(FileGenerationForFFM));  // Thread Initialize for FFM
        try      
        {                
            if ((threadITD == null) ||
                (threadITD.ThreadState == System.Threading.ThreadState.Stopped) ||
                (threadITD.ThreadState == System.Threading.ThreadState.Unstarted))
            {
                threadITD.Start();  // Thread Started for ITD
            }                  
            if ((threadCTD == null) ||
                (threadCTD.ThreadState == System.Threading.ThreadState.Stopped) ||
                (threadCTD.ThreadState == System.Threading.ThreadState.Unstarted))
            {
                threadCTD.Start(); // Thread Started for CTD
            }
            if ((threadCID == null) ||
                (threadCID.ThreadState == System.Threading.ThreadState.Stopped) ||
                (threadCID.ThreadState == System.Threading.ThreadState.Unstarted))
            {
                threadCID.Start(); // Thread Started for CID
            }                  
            if ((threadFFM == null) ||
                (threadFFM.ThreadState == System.Threading.ThreadState.Stopped) ||
                (threadFFM.ThreadState == System.Threading.ThreadState.Unstarted))
            {
                threadFFM.Start(); // Thread Started for FFM
            }
        }
        catch (Exception ex)
        {
            objErrorLog.SrtErrorText = ex.ToString().Substring(0, 25);
            objErrorLog.StrErrorDescription = ex.ToString();
            objErrorLog.WriteErrorLog(objErrorLog);
        }
        finally
        {
            scope.Complete();
        }
    }
    timerjob.start();
} 

Answer 1

这似乎已经是多线程的。尝试在每个 FileGenerationForXXX 方法的开头和结尾添加日志记录代码，这样您就可以看到四个方法一起开始和分别停止。

private void FileGenerationForITD()
{
    eventlog1.WriteEntry("FileGenerationForITD started.");
    ...
    eventlog1.WriteEntry("FileGenerationForITD finished.");
}

此外，您可以删除所有 if 语句。线程对象保证处于该状态，因为new 和Start() 之间没有任何变化。

Thread threadITD = new Thread(new ThreadStart(FileGenerationForITD));
Thread threadCTD = new Thread(new ThreadStart(FileGenerationForCTD));
// ...
try
{
    ThreadITD.Start();
    ThreadCTD.Start();
    // ...
}

编辑：回应 cmets。

为了防止计时器在线程全部完成之前第二次触发，我建议在再次启动计时器之前加入线程。 Thread.Join() 导致该线程休眠，直到引用的线程结束。所有其他线程继续不间断。

private void CsvGenFromDatabase(object sender, EventArgs e)
{
    timerjob.stop();

    using (TransactionScope scope = new TransactionScope(TransactionScopeOption.RequiresNew))
    {
        Thread threadITD = new Thread(new ThreadStart(FileGenerationForITD));
        Thread threadCTD = new Thread(new ThreadStart(FileGenerationForCTD));
        Thread threadCID = new Thread(new ThreadStart(FileGenerationForCID));
        Thread threadFFM = new Thread(new ThreadStart(FileGenerationForFFM));

        threadITD.Start();
        threadCTD.Start();
        threadCID.Start();
        threadFFM.Start();

        threadITD.Join();
        threadCTD.Join();
        threadCID.Join();
        threadFFM.Join();

        scope.Complete();
    }

    timerjob.start();  
}