mat*_*key 4 .net c# asynchronous async-await
我有一个异步控制器动作方法,它在我的后端调用4个异步方法,从每个方法返回List.每个方法的对象列表都不同.即列表清单等
我这样做是这样的:
BizProvider bp = new BizProvider();
List<biz.Customer> custReturn = await bp.GetCustomerAsync();
List<biz.Account> acctReturn = await bp.GetAccountAsync();
...plus 2 more
List<object> returnArr = new List<object>();
returnArr.Add(custReturn);
returnArr.Add(acctReturn); ...plus 2 more
return JsonConvert.SerializeObject(returnArr);
Run Code Online (Sandbox Code Playgroud)
我应该使用Task.WhenAll多个任务吗?
微软的例子 https://msdn.microsoft.com/en-us/library/hh194874%28v=vs.110%29.aspx
所有任务都返回 List<int>
所以我使用了抽象类,并且我的所有列表对象类型都继承自此.并且我更改了业务对象提供程序的返回类型以返回抽象类型的列表,所以现在我可以这样做:
var tasks1 = new List<Task<List<Biz.AbstractClass>>>();
tasks1.Add(bp.GetCustomerAsAbstractAsync());
tasks1.Add(bp.GetAccountAsAbstractAsync());
...plus 2 more
Run Code Online (Sandbox Code Playgroud)
然后我调用var continuation = Task.WhenAll(tasks1);
这会执行它到达的下一行.Results然后停止执行???
foreach (var result in continuation.Result)
^ stops here
Run Code Online (Sandbox Code Playgroud)
我打电话
returnArrays.Add(result1);
return JsonConvert.SerializeObject(returnArrays);
Run Code Online (Sandbox Code Playgroud)
但这些永远不会受到打击......我不知道为什么.也许我不需要WhenAll,但我仍然好奇出了什么问题.也许我需要等待特定的函数,或以某种方式调用Action,就像在Microsoft链接中函数被内联调用一样.
Task.Run(async () => { x=x,etc...)
Run Code Online (Sandbox Code Playgroud)
编辑20150306 =>添加更多实施细节
CustMan cm = new CustMan();
List<object> returnArr = new List<object>();
var aTask = cm.GetCustomersAsync();
var bTask = cm.GetAccountsAsync();
await Task.WhenAll(aTask, bTask);
returnArr.Add(aTask.Result);//same for bTask <-- breakpoint never hits
return JsonConvert.SerializeObject(returnArr);
//also .js ajax return method never comes back.
//in CustMan()
public async Task<List<biz.Customer>> GetCustomersAsync() {
List<biz.Customer> custList = await (from contact in ObjectContextDb.GetData<da.ContactInfo>()//<--generic returns IQueryable
join customerContact in ObjectContextDb.GetData<da.CustomerContact>() on contact.Id equals customerContact.ContactInfoID
join customerOrg in ObjectContextDb.GetData<da.CustomerOrganisation>() on customerContact.OrgID equals customerOrg.Id
orderby contact.LastName
select new biz.Customer {
CustomerContactInfo = new biz.Contact() {
ID = contact.Id,
WorkPhone = contact.WorkPhone
},
CustomerOrg = new biz.CustomerOrganisation {
ID = facultyOrg.Id,
Name = facultyOrg.OrgName,
ClientID = (customerContact.ClientID.HasValue ? customerContact.ClientID.Value : 0)
}
}).ToListAsync<biz.Customer>();
return custList;// <-- Breakpoint hits here, the List has items
}
public async Task<List<biz.Account>> GetAccountsAsync()
{
var roles = (from acctType in ObjectContextDb.GetData<da.AccountInType>()
join r in ObjectContextDb.GetData<da.AccountType>() on acctType.AccountTypeID equals r.ID
select new
{
AccountId = acctType.AccountID,
Type = r.TypeName
}); //.ToList();
List<biz.Account> allContacts = await (from account in ObjectContextDb.GetData<da.Account>()
orderby account.Name
select new biz.Account()
{
Number = account.Id,
Name = account.Name,
Roles = (from r in roles where account.Id == r.AccountId select r.Type).ToList()
}).ToListAsync<biz.Account>();
return allContacts;// <-- Breakpoint hits here, the List has items
}
Run Code Online (Sandbox Code Playgroud)
无需调用Manager类方法的方法WhenAll!
CustMan cm = new CustMan();
List<object> returnArrays = new List<object>();
List<biz.Customer> custReturn = await cm.GetCustomersAsync();
List<biz.Account> acctReturn = await cm.GetAccountsAsync();
returnArrays.Add(custReturn);
returnArrays.Add(acctReturn);
return JsonConvert.SerializeObject(returnArrays);
Run Code Online (Sandbox Code Playgroud)
你可以Task.WhenAll不用改变任何东西.只需将任务存储在变量中,然后添加其结果:
var aTask = GetAAsync();
var bTask = GetBAsync();
...
await Task.WhenAll(aTask, bTask);
returnArr.Add(aTask.Result);
returnArr.Add(bTask.Result);
Run Code Online (Sandbox Code Playgroud)
但是,在您的情况下,异步操作使用不同时支持多个操作的实体框架,因此您无法执行此操作.
一次呼叫并等待您的操作:
returnArr.Add(await GetAAsync());
returnArr.Add(await GetBAsync());
...
Run Code Online (Sandbox Code Playgroud)