c# - 等待锁定执行的任务数组

Question

可以从代码中的多个位置调用 TestAwaitTaskArrayAsync()。我需要锁定 taskArray 的执行并异步等待直到它的所有任务完成，然后下一次调用才会开始执行 taskArray。这是代码:

private async Task TestAwaitTaskArrayAsync()
        {
            Task[] taskArray;
            lock (_lock_taskArray)
            {
              taskArray = new Task[]
              {
                Task.Run(() =>
                {
                    SomeMethod1();
                }),
                Task.Run(() =>
                {
                    SomeMethod2();
                })
              };
            }
            await Task.WhenAll(taskArray);
        }

不允许在锁中等待，所以我可以使用 AsyncLock如有必要，但尽量保持简单。此代码是否正确且线程安全？我不确定是否 await Task.WhenAll(taskArray);可以在锁之外，我应该改用 AsyncLock 吗？

Answer 1

您使用的锁几乎没有效果，因为创建任务非常快并且不会与任何东西发生冲突。在异步设置中实现互斥的方法是使用 SemaphoreSlim 类。它是一个支持任务异步模式的锁。

    SemaphoreSlim sem = new SemaphoreSlim(1);
    private async Task TestAwaitTaskArrayAsync()
    {
        await sem.WaitAsync();
        try {
         Task[] taskArray = new Task[]
           {
             Task.Run(() =>
             {
                 SomeMethod1();
             }),
             Task.Run(() =>
             {
                 SomeMethod2();
             })
           };
         }
         await Task.WhenAll(taskArray);
        }
        finally { sem.Release(); }
    }

以同步方式这会更容易:

lock (_lock_taskArray)
 Parallel.Invoke(() => SomeMethod1(), () => SomeMethod2());

完成。

如果您愿意，也可以使用 AsyncLock。这应该允许您使用 using 结构来可靠地释放锁。