等待多个命令行进程完成？

Question

我有一个需要执行许多命令行脚本的需求。它们当前存储在一个List中。我想同时运行所有这些脚本，并在所有脚本都完成后才进行下一步操作。

我尝试了下面展示的方法，但发现它存在缺陷，因为最后一个命令不一定会最后“结束”。事实上，我发现最后一个命令甚至可能是第一个完成的。所以，我认为我需要像WaitForExit()这样的东西，但它只有在所有执行进程都完成后才返回。

for (int i = 0; i < commands.Count; i++)
{
    string strCmdText = commands[i];
    var process = System.Diagnostics.Process.Start("CMD.exe", strCmdText);
    if (i == (commands.Count - 1))
    {
        process.WaitForExit();
    }
}
//next course of action once all the above is done

- fishmong3r

Answer 1

由于每次调用 Process.Start 都会启动一个新的进程，因此您可以单独跟踪它们，像这样：

var processes = new List<Process>();
for (int i = 0; i < commands.Count; i++)
{
    string strCmdText = commands[i];
    processes.Add(System.Diagnostics.Process.Start("CMD.exe", strCmdText));
}

foreach(var process in processes)
{
    process.WaitForExit();
    process.Close();
}

编辑

Process.Close() 已添加，如评论所述。

- Ben Aaronson

---

我认为这个解决方案比任何提供的任务并行方法都要好，因为它不会不必要地使用/创建更多的线程。 - Edin

需要调用process.Close()吗？http://msdn.microsoft.com/en-us/library/fb4aw7b8%28v=vs.110%29.aspx - Philip Pittle

可能并不是必须的，因为Process从Component继承了一个终结器，但是及早处理是一个好习惯。在这个例子中也很容易做到（只需在每个循环迭代后调用WaitForExit()之后的Close()即可）。 - Mike Strobel

@Edin 没错。我不认为有任何理由假装你的程序正在进行并行处理，而实际上只是同时运行的外部进程。 - Ben Aaronson

Answer 2

使用任务数组并等待它们全部完成。

var tasks = new Task[commands.Count];
for (int i = 0; i < commands.Count; i++)
{
    tasks[i] = Task.Factory.StartNew(() => {
       string strCmdText = commands[i];
       var process = System.Diagnostics.Process.Start("CMD.exe", strCmdText);
       process.WaitForExit();
    });
}

Task.WaitAll(tasks);

或者，更像LINQ的写法如下：

var tasks = commands.Select(strCmdText => Task.Factory.StartNew(() => {
    var process = System.Diagnostics.Process.Start("CMD.exe", strCmdText);
    process.WaitForExit();
})).ToArray();
Task.WaitAll(tasks);

- Chris Hinton

Answer 3

至少在Windows上，您可以使用WaitHandle.WaitAll()。

using System;
using System.Diagnostics;
using System.Threading;
using Microsoft.Win32.SafeHandles;
using static System.FormattableString;

public class ProcessWaitHandle : WaitHandle
{
    public ProcessWaitHandle(Process process) =>
        this.SafeWaitHandle = new SafeWaitHandle(process.Handle, false);
}

class Program
{
    static void Main(string[] args)
    {
        int processesCount = 42;
        var processes = new Process[processesCount];
        var waitHandles = new WaitHandle[processesCount];
        try
        {
            for (int i = 0; processesCount > i; ++i)
            {
                // exit immediately with return code i
                Process process = Process.Start(
                    "cmd.exe",
                    Invariant($"/C \"exit {i}\""));

                processes[i] = process;
                waitHandles[i] = new ProcessWaitHandle(process);
            }

            WaitHandle.WaitAll(waitHandles);
            foreach (Process p in processes)
            {
                Console.Error.WriteLine(
                    Invariant($"process with Id {p.Id} exited with code {p.ExitCode}"));
            }
        }
        finally
        {
            foreach (Process p in processes)
            {
                p?.Dispose();
            }

            foreach (WaitHandle h in waitHandles)
            {
                h?.Dispose();
            }
        }

        Console.WriteLine("Press any key to continue...");
        Console.ReadKey(false);
    }
}

这种方法还可以使用其他WaitAll重载，并且可以设置超时等待。

- Fritjof Mayer