以一个简单的酒店实体为例:

class Hotel
{
    public int NumberOfRooms { get; set; }
    public int StarRating { get; set; }
}

请考虑以下C#5.0中的代码:
public void Run()
{
    var hotel = new Hotel();
    var tasks = new List<Task> { SetRooms(hotel), SetStars(hotel) };
    Task.WaitAll(tasks.ToArray());
    Debug.Assert(hotel.NumberOfRooms.Equals(200));
    Debug.Assert(hotel.StarRating.Equals(5));
}

public async Task SetRooms(Hotel hotel)
{
    await Task.Delay(TimeSpan.FromSeconds(1)).ConfigureAwait(false);
    hotel.NumberOfRooms = 200;
}

public async Task SetStars(Hotel hotel)
{
    await Task.Delay(TimeSpan.FromSeconds(1)).ConfigureAwait(false);
    hotel.StarRating = 5;
}

对Debug.Assert()的两个调用均成功通过。我不明白在完成两个任务之后,Hotel实例如何包含并行运行的两个方法的赋值。

我以为,当await(在SetRooms()SetStars()都被调用)时,将创建酒店实例的“快照”(将NumberOfRoomsStarRating都设置为0)。因此,我的期望是两个任务之间存在竞争条件,最后一个要运行的条件是将一个任务复制回hotel,从而在两个属性之一中产生0。

显然我错了。您能解释我在哪里误解了等待的工作方式吗?

最佳答案



您的Hotel类是引用类型。当您使用async-await时,您的方法将转换为状态机,并且该状态机将对变量的引用悬挂到该状态机上。这意味着创建的两个状态机都指向相同的Hotel实例。没有Hotel的“快照”或深拷贝,编译器不会这样做。

如果您想查看实际发生的情况,请you can have a look at what the compiler emits转换您的异步方法后:

[AsyncStateMachine(typeof(C.<SetRooms>d__1))]
public Task SetRooms(Hotel hotel)
{
    C.<SetRooms>d__1 <SetRooms>d__;
    <SetRooms>d__.hotel = hotel;
    <SetRooms>d__.<>t__builder = AsyncTaskMethodBuilder.Create();
    <SetRooms>d__.<>1__state = -1;
    AsyncTaskMethodBuilder <>t__builder = <SetRooms>d__.<>t__builder;
    <>t__builder.Start<C.<SetRooms>d__1>(ref <SetRooms>d__);
    return <SetRooms>d__.<>t__builder.Task;
}
[AsyncStateMachine(typeof(C.<SetStars>d__2))]
public Task SetStars(Hotel hotel)
{
    C.<SetStars>d__2 <SetStars>d__;
    <SetStars>d__.hotel = hotel;
    <SetStars>d__.<>t__builder = AsyncTaskMethodBuilder.Create();
    <SetStars>d__.<>1__state = -1;
    AsyncTaskMethodBuilder <>t__builder = <SetStars>d__.<>t__builder;
    <>t__builder.Start<C.<SetStars>d__2>(ref <SetStars>d__);
    return <SetStars>d__.<>t__builder.Task;
}

您可以看到这两种方法都将hotel变量提升到其状态机中。



现在您了解了编译器的实际功能,您可以了解到确实没有竞争条件。它是被修改的Hotel的同一实例,每种方法都设置了不同的变量。

旁注

也许您以编写此代码为例来解释您的问题,但是如果您已经在创建异步方法,则建议您使用Task.WhenAll而不是阻塞的Task.WaitAll。这意味着将Run的签名更改为async Task而不是void:
public async Task RunAsync()
{
    var hotel = new Hotel();
    await Task.WhenAll(SetRooms(hotel), SetStars(hotel));
    Debug.Assert(hotel.NumberOfRooms.Equals(200));
    Debug.Assert(hotel.StarRating.Equals(5));
}

关于c# - C#Task.WaitAll()如何将对象状态组合为一个?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/34264743/

10-12 01:47