可以从多个线程等待相同的任务 - 等待线程安全吗?

Pal*_*alo 27 c# asynchronous thread-safety async-await

等待线程安全吗?似乎Task类是线程安全的,所以我猜等待它也是线程安全的,但我还没有在任何地方找到确认.线程安全也是定制awaiter的要求 - 我的意思是IsCompleted,GetAwaiter等方法?即如果这些方法不是线程安全的,那么等待是否是线程安全的?但是,我不希望很快就需要定制的等待者.

用户场景的一个示例:假设我有一个后台任务,它以异步方式返回结果,然后从多个线程使用:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace scratch1
{
    class Foo
    {
        Task<int> _task;

        public Foo()
        {
            _task = Task.Run(async () => { await Task.Delay(5000); return 5; });
        }

        // Called from multiple threads
        public async Task<int> Bar(int i)
        {
            return (await _task) + i;
        }
    }

    class Program
    {
        public static void Main(string[] args)
        {
            Foo foo = new Foo();

            List<Task> tasks = new List<Task>();
            foreach (var i in Enumerable.Range(0, 100))
            {
                tasks.Add(Task.Run(async () => { Console.WriteLine(await foo.Bar(i)); })); 
            }

            Task.WaitAll(tasks.ToArray());
        }
    }
}
Run Code Online (Sandbox Code Playgroud)

SLa*_*aks 15

正如你所提到的await那样,它足够薄,以至于它首先看不到线程.

await(状态机中编译器生成的代码和BCL中的支持类)相关联的代码一次只能在一个线程上运行.(它可以在从等待状态返回时切换到不同的线程,但之前的运行已经完成)

实际的线程安全性取决于您正在等待的对象.
它必须具有线程安全的方式来添加回调(或者await一次两次可能会中断).

此外,它必须只调用一次回调,否则可能会破坏状态机.(特别是,如果它同时在两个线程上运行它的回调,事情会发生可怕的错误)

Task 是线程安全的.

  • 你的第一个陈述可能误导人们认为"等待"从根本上说是不安全的......而我认为你的意思是它本身既不安全也不安全 - 它只是委托等待的任何东西,如果那是"任务",你就没事了. (6认同)
  • 绝对可以,谢谢。尽管“将仅在一个线程上运行”可能应该是“每次方法调用(对应于状态机的单个实例)一次仅在一个线程上运行”。它当然可以在“await”点的线程之间跳转,但它不会在多个线程上同时运行。(至少不会,除非你严重滥用它......这总是很有趣。) (3认同)