以一个简单的酒店实体为例:
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()
都被调用)时,将创建酒店实例的“快照”(将NumberOfRooms
和StarRating
都设置为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/