信号量和多线程 Process.Start 的问题

Question

不确定我下面的代码有什么问题，但没有按预期工作。设计是允许用户从 ListBox 中选择任意数量的输入文件，然后单击“执行”按钮以使用不同的输入文件启动相同的可执行文件。我将添加一个控件以允许用户指定并发进程的数量，但现在我将硬编码为 3 以进行测试。我的期望是每个可执行文件将按顺序开始（尽管我知道它们可能不会以这种方式完成）并且一次只会执行 3 个（尽管这个数字最终将由用户输入控件控制）。我想为调用进程的函数增加额外的功能，即任务优先级，返回退出代码，但现在我无法让基本功能正常工作。我已经尝试了在这个网站和网络上的其他网站上找到的许多代码变体，但仍然无法让它工作。这是当前版本：

    private void btnParserExe_Click(object sender, EventArgs e)
    {
        Pool = new Semaphore(3,3);  //Pool above declared as class variable 
        string ExeName = "C:\\Program Files (x86)\\Norman\\bin\\OC2.exe";
        string Args;
        string ArgDir = this.dirListBox1.Path + "\\";

        for (int i = 0; i < this.fileListBox1.Items.Count; i++)
        {
            if (this.fileListBox1.GetSelected(i) == true)
            {
                Args = "-i " + this.fileListBox1.get_Items(i) + " -r -c -noerr";
                Thread thread = new Thread(() => DoWork(ArgDir, ExeName, Args, "3"));
                thread.Start();
            }
        }
    }


    private static void DoWork(string WorkingDir, string exefile, string parameters, string priority)
    {
        Pool.WaitOne();

        Process exeProcess = new Process();
        int exitCode;

        try
        {
            exeProcess.StartInfo.FileName = exefile;
            exeProcess.StartInfo.Arguments = parameters;
            exeProcess.StartInfo.WorkingDirectory = WorkingDir;
            exeProcess.Start();
            exeProcess.WaitForExit();
        }
        catch (Exception ex)
        {
            MessageBox.Show("ERROR EXECUTING: " + parameters + " " + ex.Message);
        }
        finally
        {
            exitCode = exeProcess.ExitCode;
        }
        Pool.Release();
    }

}

我遇到的三个主要问题：

1. 作业并不总是以正确的顺序开始（ListBox 中较低的一些项目在其他较高的项目之前启动）
2. 有时启动的进程似乎停止了，好像它已经完成但窗口仍然在屏幕上。这是一个非常一致的问题，但并不总是相同的任务/输入文件会停止。有时，在先前的测试中运行良好的会停止运行，反之亦然。
3. 我的笔记本电脑在测试这部分代码时重新启动？？

任何反馈、链接、示例将不胜感激。

Answer 1

1. 无法保证线程实际启动的顺序。两个线程快速连续启动（在Thread.Start() 意义上）很有可能会遇到“第二个”线程实际上在“第一个”之前开始执行。如果有序执行很重要，您将需要序列化它们的执行（这似乎避免了启动多个线程的需要。）

2. 我很好奇您是否确定所有进程都以正确的输入文件名启动。在我看来，您的委托使用情况实际上可能最终导致两个使用同一个文件启动，我想知道这是否会导致您的第二个问题。

3. 多久一次？您的计算机此时是否在执行其他操作？您是否收到任何消息、蓝屏死机或任何形式的信息？这无论如何都不正常。

Answer 2

.Net 4.0 现在为简单的并行任务提供了一些新工具： http://msdn.microsoft.com/en-us/library/dd987838(v=vs.100).aspx

    string ExeName = "C:\\Program Files (x86)\\Norman\\bin\\OC2.exe";
    string Args;
    string ArgDir = "\\";

    //Simulated listbox items here:
    string[] filelist = new string[] {"file1", "file2"};

    System.Threading.Tasks.ParallelOptions options = new System.Threading.Tasks.ParallelOptions();
    options.MaxDegreeOfParallelism = 3;
    System.Threading.Tasks.Parallel.For(0, 10, options, (i => {

        Args = "-i " + filelist[i] + " -r -c -noerr";
        DoWork(ArgDir, ExeName, Args, "3");
    }
        ));
}

使用Parallel.For可以管理并发，任务按顺序启动。

在 .Net 2.0 中，您可以使用一些 BackgroundWorkers 和一个简单的控制器方法。比如：

Stack<string> filelist = new Stack<string>() {"file1", "file2"};

private void Setup()
{

    System.ComponentModel.BackgroundWorker backgroundWorker1;
    System.ComponentModel.BackgroundWorker backgroundWorker2;

    backgroundWorker1.DoWork += new DoWorkEventHandler(backgroundWorker_DoWork);
    backgroundWorker1.RunWorkerCompleted += new RunWorkerCompletedEventHandler(backgroundWorker_RunWorkerCompleted);

    backgroundWorker2.DoWork += new DoWorkEventHandler(backgroundWorker_DoWork);
    backgroundWorker2.RunWorkerCompleted += new RunWorkerCompletedEventHandler(backgroundWorker_RunWorkerCompleted);
}

private void Execute()
{
    backgroundWorker1.DoWork();
    backgroundWorker2.DoWork();
}

private string GetNextItem()
{
    //this is a crude controller
    return filelist.Pop();
}

private void backgroundWorker_DoWork(object sender, DoWorkEventArgs e)
{   
    // Get the BackgroundWorker that raised this event.
    BackgroundWorker worker = sender as BackgroundWorker;
    string nextFile = GetNextItem();
    //Some simple check here to see if there were any items left or quit
    ....
    //Now do work
    Args = "-i " + nextFile  + " -r -c -noerr";
    DoWork(ArgDir, ExeName, Args, "3");

}

private void backgroundWorker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{   
    // Check for errors...
    ...

    // See if more work to do
    if (filelist.Count > 0)
    {
        //Repeat task
        BackgroundWorker worker = sender as BackgroundWorker;
        worker.DoWork();
    }
}

使用 BackgroundWorkers，您还可以拥有独立的进度条等。

代码未经测试。