Task.Run( asnyc () => ) 阻塞/不运行所有任务 C#

Question

问题是我尝试多次运行 RunPrivateMethod()，但遇到阻塞问题，或者在使用 async/await 时直接无法正常工作。而不是在这里分享每一次尝试，我只是把我当前的版本。

在 RunPrivateMethod() 中，exeProcess.WaitForExit() 方法是一个外部程序，基本上是读取/写入/处理/输出数据。我尝试将此作为异步任务运行，但它不起作用。

我不知道这是否合理，但我想限制一次启动的任务数量，所以我在每个案例块的末尾放入了 Task.WaitAll()。案例 (1) 和案例 (2) 始终都会运行。

所以，这是我的代码。目前，它在加载每个任务时会阻塞。然后似乎只有最后一个任务在运行。如果我取出所有任务语句并正常运行一切，它就可以正常工作。

我真的非常感谢您对此的任何意见或帮助。我的大部分测试最终都会锁定我的系统和键盘。

public void RunSomeTasks(int group)
    {

        switch (group)
        {

            case (1):
                {
                    Task.Run(async () => await RunAsyncMethod(param1, param1, group));
                    Task.Run(async () => await RunAsyncMethod(param1, param2, group));
                    Task.Run(async () => await RunAsyncMethod(param1, param3, group));
                    Task.WaitAll();
                    break;
                }
            case (2):
                {
                    Task.Run(async () => await RunAsyncMethod(param2, param1, group));
                    Task.Run(async () => await RunAsyncMethod(param2, param2, group));
                    Task.Run(async () => await RunAsyncMethod(param2, param3, group));
                    Task.WaitAll();
                    break;
                }
        }
    }

    async Task RunAsyncMethod(string var1, string var2, string varGroup)
    {           

        ////////////////////////////////////////////
        // Use ProcessStartInfo class
        ProcessStartInfo startInfo = new ProcessStartInfo();
        startInfo.CreateNoWindow = false;
        startInfo.UseShellExecute = false;
        startInfo.FileName = "SomeOutsideEXE";
        startInfo.WindowStyle = ProcessWindowStyle.Hidden;
        startInfo.Arguments = var1 + " " + var2 + " " + varGroup;
        using (Process exeProcess = Process.Start(startInfo))
        {
            // did not work -> Task.Run(() => exeProcess.WaitForExit()).Wait();
            exeProcess.WaitForExit();
        }
    }
}

我为此工作了无数小时并阅读了 Cleary 的书，最新版本是这篇文章的一个版本：Aync/Await action within Task.Run() 目前的结果是，尽管 exeProcess 的启动时间正确，但每组中的最后一个任务仍然有效。我无法在键盘运行时使用它。

我显然为 RunSomeTasks() 尝试了一个直接的异步方法，然后首先等待 RunAsyncMethod。我真的可以使用一些帮助，是的，我已经知道我不知道我在做什么，尽管我花了很长时间阅读和试错。

Answer 1

我稍微修改了您的示例，这应该可以防止 UI 锁定。请注意，我在按钮单击中添加了async。也使用 WhenAll 并传入已启动的任务，而不是使用 WaitAll。 （更新为完全异步模式）

    private async void button1_Click(object sender, EventArgs e)
    {
        try
        {
            await RunSomeTasks(1);
            await RunSomeTasks(2);
            lblStatus.Text = "done!";
        }
        catch (Exception ex)
        {
            MessageBox.Show(ex.ToString());
        }
    }

    public async Task RunSomeTasks(int group)
    {
        switch (group)
        {
            case (1):
                {
                    var t1 = RunMethodAsync(param1, param1, group);
                    var t2 = RunMethodAsync(param1, param2, group);
                    var t3 = RunMethodAsync(param1, param3, group);
                    await Task.WhenAll(t1, t2, t3).ConfigureAwait(false);
                    break;
                }
            case (2):
                {
                    var t1 = RunMethodAsync(param2, param1, group);
                    var t2 = RunMethodAsync(param2, param2, group);
                    var t3 = RunMethodAsync(param2, param3, group);
                    await Task.WhenAll(t1, t2, t3).ConfigureAwait(false);
                    break;
                }
        }
    }

    async Task RunMethodAsync(string var1, string var2, int varGroup)
    {
        ////////////////////////////////////////////
        // Use ProcessStartInfo class
        ProcessStartInfo startInfo = new ProcessStartInfo();
        startInfo.CreateNoWindow = false;
        startInfo.UseShellExecute = false;
        startInfo.FileName = "SomeOutsideEXE";
        startInfo.WindowStyle = ProcessWindowStyle.Hidden;
        startInfo.Arguments = var1 + " " + var2 + " " + varGroup;

        using (Process exeProcess = new Process())
        {
            var cts = new TaskCompletionSource<int>();

            exeProcess.StartInfo = startInfo;
            exeProcess.EnableRaisingEvents = true;

            exeProcess.Exited += (sender, e) =>
            {
                try
                {
                    cts.SetResult(exeProcess.ExitCode);
                }
                catch (Exception ex)
                {
                    cts.SetException(ex);
                }
            };

            exeProcess.Start();

            await cts.Task.ConfigureAwait(false);
        }
    }

Answer 2

我想出的最干净的方式来做一个awaitProcess.WaitForExit 就是这样，节省订阅events 等。

private async Task RunRubyScript(string filePath)
{
  await Task.Run(() =>
  {
    using (var proc = new Process())
    {
      var startInfo = new ProcessStartInfo(@"ruby");
      startInfo.Arguments = filePath;
      startInfo.UseShellExecute = false;
      startInfo.CreateNoWindow = true;
      proc.StartInfo = startInfo;
      proc.Start();
      proc.WaitForExit();
    }
  });
}

这是为了运行 ruby 脚本，但显然要相应地修改 ProcessStartInfo 以满足您的要求。

希望这会有所帮助！