在多任务环境中执行进程

Question

我正在执行一些命令，我​​正在使用System.Diagnostics.Process。我设法设置它的工作，当我一一执行命令时，返回是正确的。然后我试图通过为每个流程执行创建任务来加速流程，这里是我遇到问题的地方。

这里是执行命令的类：

class ProcessExec 
{ 
    public string Start(string command) 
    { 
     string res = ""; 

     Process process = new Process(); 
     process.EnableRaisingEvents = true; 
     process.StartInfo.FileName = "powershell.exe"; 
     process.StartInfo.Arguments = command; 
     process.StartInfo.UseShellExecute = false; 
     process.StartInfo.RedirectStandardOutput = true; 
     process.StartInfo.CreateNoWindow = true; 

     process.OutputDataReceived += (object sender, DataReceivedEventArgs e) => 
     { 
      res = res + e.Data; 
     }; 

     process.Start(); 
     process.BeginOutputReadLine(); 
     process.WaitForExit(10000); 

     return res; 
    } 
} 

，这是我公司主营：

class Program 
{ 
    static void Main(string[] args) 
    { 
     Console.WriteLine("Start"); 

     List<Task> tasks = new List<Task>(); 

     ProcessExec exec = new ProcessExec(); 

     Stopwatch sw = new Stopwatch(); 
     sw.Start(); 

     string res1 = ""; 
     tasks.Add(Task.Run(() => { res1 = exec.Start("date"); })); 
     string res2 = ""; 
     tasks.Add(Task.Run(() => { res2 = exec.Start("hostname"); })); 
     string res3 = ""; 
     tasks.Add(Task.Run(() => { res3 = exec.Start("date"); })); 
     string res4 = ""; 
     tasks.Add(Task.Run(() => { res4 = exec.Start("date"); })); 
     string res5 = ""; 
     tasks.Add(Task.Run(() => { res5 = exec.Start("date"); })); 
     string res6 = ""; 
     tasks.Add(Task.Run(() => { res6 = exec.Start("ipconfig"); })); 
     string res7 = ""; 
     tasks.Add(Task.Run(() => { res7 = exec.Start("date"); })); 
     string res8 = ""; 
     tasks.Add(Task.Run(() => { res8 = exec.Start("date"); })); 

     Task.WaitAll(tasks.ToArray()); 

     sw.Stop(); 

     Console.WriteLine(sw.Elapsed.TotalSeconds); 

     Console.WriteLine("1 - " + res1); 
     Console.WriteLine("2 - " + res2); 
     Console.WriteLine("3 - " + res3); 
     Console.WriteLine("4 - " + res4); 
     Console.WriteLine("5 - " + res5); 
     Console.WriteLine("6 - " + res6); 
     Console.WriteLine("7 - " + res7); 
     Console.WriteLine("8 - " + res8); 

     Console.WriteLine("End"); 
     Console.ReadKey(); 
    } 
} 

这是我的输出：

Start 
7,4867498 
1 - 22 de julho de 2017 10:25:46  
2 -  
3 - 22 de julho de 2017 10:25:48 
4 - 22 de julho de 2017 10:25:48  
5 -  
6 -  
7 - 22 de julho de 2017 10:25:48 
8 - 22 de julho de 2017 10:25:48 
End 

现在，我认为，我的问题与OutputDataReceived事件处于不同的线程有关，但我不完全确定。任何人都知道什么是问题，我该如何解决它？

Answer 1

如果你不仅能够解释你得到的输出是什么，而且还能得到你想要的输出会更好。也就是说，它看起来像你所问的是为什么一些（但不是全部）你的命令有空输出。是的，那将是因为这些命令显然需要超过您分配的10秒的时间，所以您的方法在输出读取之前返回。

事实是，如果您希望您的方法在流程完成后才能返回，那么根本没有理由使用WaitForExit()。我知道这听起来不符合直觉，但是您必须在这里使用WaitForExit()的原因是您选择异步使用过程输出。但是没有理由这样做，因为你希望处理过程是同步的。

所以，就这么做。您可以拨打Process.StandardOutput.ReadToEnd()，这会阻止进程退出，然后返回所有输出。此外，似乎没有任何理由让你的类是非静态的，因为它没有任何状态，除了方法中的本地状态外。

因此，像这样效果会更好：

static class ProcessExec 
{ 
    public static string Start(string command) 
    { 
     Process process = new Process(); 
     process.StartInfo.FileName = "powershell.exe"; 
     process.StartInfo.Arguments = command; 
     process.StartInfo.UseShellExecute = false; 
     process.StartInfo.RedirectStandardOutput = true; 
     process.StartInfo.CreateNoWindow = true; 

     process.Start(); 

     return process.StandardOutput.ReadToEnd(); 
    } 
} 

我会改变你的执行的另一件事是使用局部变量。如果您使用Task来代表Task对象本身的命令结果，而不是为您执行的每个命令捕获本地变量，那会更好。

例如：

static void Main(string[] args) 
{ 
    Console.WriteLine("Start"); 

    List<Task<string>> tasks = new List<Task<string>>(); 

    Stopwatch sw = new Stopwatch(); 
    sw.Start(); 

    tasks.Add(Task.Run(() => ProcessExec.Start("date"))); 
    tasks.Add(Task.Run(() => ProcessExec.Start("hostname"))); 
    tasks.Add(Task.Run(() => ProcessExec.Start("date"))); 
    tasks.Add(Task.Run(() => ProcessExec.Start("date"))); 
    tasks.Add(Task.Run(() => ProcessExec.Start("date"))); 
    tasks.Add(Task.Run(() => ProcessExec.Start("ipconfig"))); 
    tasks.Add(Task.Run(() => ProcessExec.Start("date"))); 
    tasks.Add(Task.Run(() => ProcessExec.Start("date"))); 

    Task.WaitAll(tasks); 

    sw.Stop(); 

    Console.WriteLine(sw.Elapsed.TotalSeconds); 

    Console.WriteLine(string.Join(Environment.NewLine, 
     tasks.Select((t, i) => $"{i + 1} - {t.Result}"))); 

    Console.WriteLine("End"); 
    Console.ReadKey(); 
} 

那么你不需要的变量，并且很容易使用循环变量，而不必单独命名每一个检索命令的结果。