多线程 - For 循环不会等待 Await

Question

我有一个控制台应用程序有两个线程：

    public static async void Thread1()
        {
            for (int i = 0; i < 100; i++)
            {
                Debug.WriteLine("Thread1 " + i);
                await MyFunc();
            }
        }

    public static async void Thread2()
        {
            for (int i = 0; i < 100; i++)
            {
                Debug.WriteLine("Thread2 " + i);
                await MyFunc();
            }
        }
    public static void Main(string[] args)
        {
            MainAsync(args).GetAwaiter().GetResult();
        }
    private static async Task MainAsync(string[] args)
        {

            Console.WriteLine("Before start thread");

            Thread tid1 = new Thread(Thread1);
            Thread tid2 = new Thread(Thread2);

            tid1.Start();

            tid2.Start();
        }

    public static async Task MyFunc()
        {
         //do something
        }

但是，当应用程序运行并终止时，似乎每个线程只运行一次，因为我只在输出中看到以下内容：

 Before start thread
    Thread1 0
    Thread2 0
//some thing from MyFunc

我希望或者宁愿不想在 for 循环之前运行每个线程。在我看来，尽管等待，for 循环仍会继续运行。 如果是，还有什么其他可能的方法。

任何线索都会有所帮助。

Answer 1

你没有做任何事情来等待线程。主程序将继续执行，直到它返回到 O/S，这将杀死进程和所有子线程。由于您没有做任何其他事情，这几乎会立即发生，从而缩短两个线程的寿命。

如果你想等待线程完成，你可以参考this answer并写一些变体

while (thread1.IsAlive || thread2.IsAlive)
{
    //Do something to wait
}

...在退出之前。

话虽如此，您可能应该使用任务而不是线程，例如

public static async Task Task1()
{
    for (int i = 0; i < 100; i++)
    {
        Debug.WriteLine("Task1 " + i);
        await MyFunc();
    }
}

public static async Task Task2()
{
    for (int i = 0; i < 100; i++)
    {
        Debug.WriteLine("Task2 " + i);
        await MyFunc();
    }
}

然后执行并等待他们两个：

Task.WaitAll
( 
    new[] 
    {
        Task1(), 
        Task2() 
    } 
);

See this code in action on DotNetFiddle

另见What is the difference between tasks and threads?

Answer 2

您似乎对线程和任务的角色有很多困惑，因此最好阅读一下。 Steven Cleary 对此有很好的报道。 "There Is No Thread"

从 cmets 看来，您的实际意图似乎是并行运行两个 async 任务，然后等待它们都完成。

如果您想等待两个异步任务并行完成，请确保您的 async 方法实际上返回 Task 然后：

Task task1 = DoSomethingAsync(); //don't await
Task task2 = DoSomethingElseAsync(); //don't await

那么你可以异步等待Task.WhenAll：

await Task.WhenAll(task1,task2);

你真的不需要参与Thread。

Answer 3

使用异步 Task 而不是 async void

private static async Task MainAsync(string[] args)
{
    Console.WriteLine("Before start thread");
    var task1 = Thread1();
    var task2 = Thread2();
    var taskList = new [] { task1, task2 };
    Task.WaitAll(taskList);
}