Rud*_*ira 2 c# linq asynchronous entity-framework async-await
我想分享一下,我经历了其他类似的帖子,但建议的解决方案对我不起作用,这就是我创建一个单独的线程的原因.我正在尝试使用实体框架中的异步编程加入这两个结果.我有三个方法如下:
该方法PreprocessAppointment()
等待其他两种方法GetApptTask()
和GetZoneTask()
public async void PreprocessAppointment()
{
var task_1 = GetApptTask();
var task_2 = GetZoneTask();
await Task.WhenAll(task_1, task_2);
}
Run Code Online (Sandbox Code Playgroud)
该方法GetApptTask()
不会给出任何错误.
public async Task<IEnumerable<appointments>> GetApptTask(){
var result = db.appointments.Where(d => d.appt_client_id == 15 && d.customer_id == 68009);
return await result.ToListAsync();
}
Run Code Online (Sandbox Code Playgroud)
该方法GetZoneTask()
给出以下错误.IEnumerable <zones> does not contain definition for ToListAsync()
.
public async Task <IEnumerable<zones>> GetZoneTask()
{
var result = db.zones.Where(d => d.zone_client_id == "15").AsEnumerable().Distinct<zones>(new zones.Comparer());
return await result.ToListAsync();
}
Run Code Online (Sandbox Code Playgroud)
我无法找出什么可能导致这个错误.我附上的车型结构,以及用于appointments
和zones
下方.除了字段之外,模型之间的唯一区别是Comparer
类的定义zones
.
zones.cs
public class zones
{
[Column(Order=0),Key]
[StringLength(50)]
public string zone_client_id { get; set; }
//public int zone_client_id { get; set; }
[Column(Order = 1), Key]
[StringLength(5)]
public string zip { get; set; }
[StringLength(50)]
public string zone { get; set; }
public class Comparer : IEqualityComparer<zones>
{
public bool Equals(zones x, zones y)
{
return x.zone_client_id == y.zone_client_id
&& x.zip == y.zip
&& x.zone == y.zone;
}
public int GetHashCode(zones obj)
{
return obj.zone_client_id.GetHashCode() ^
obj.zip.GetHashCode() ^
obj.zone.GetHashCode();
}
}
}
Run Code Online (Sandbox Code Playgroud)
appointments.cs
public partial class appointments
{
public int appt_client_id { get; set; }
public int customer_id { get; set; }
[Key]
public int appt_id { get; set; }
public DateTime appt_date_time { get; set; }
[StringLength(200)]
public string recording_uri { get; set; }
public DateTime time_stamp { get; set; }
[Required]
[StringLength(20)]
public string appt_status { get; set; }
[Required]
[StringLength(5)]
public string appt_type { get; set; }
}
Run Code Online (Sandbox Code Playgroud)
ToListAsync()
IQueryable<T>
只在一个人工作,当你把它变成一个IEnumerable<T>
通道时,AsEnumerable()
你就失去了调用它的能力.
因为无论如何AsEnumerable()
你一直在使用内存集合,只需在那时列出一个列表.
var allZones = await db.zones.Where(d => d.zone_client_id == "15").ToListAsync().ConfigureAwait(false);
return allZones.Distinct<zones>(new zones.Comparer()).ToList();
Run Code Online (Sandbox Code Playgroud)
最后一个.ToList()
是可选的.如果你不这样做并且多次枚举返回的IEnumerable,你将多次运行Distinct
.做一个额外的操作.ToList()
使它"记住"结果,Distinct
而不是重新计算它.
由于 ToListAsync() 仅适用于 IQueryable,因此当您通过 AsEnumerable() 将其转换为 IEnumerable 时,您将无法调用它。您可以对 IEnumerable 序列调用 .AsQueryable(),它将返回 IQueryable。
例如:
private async Task<List<MyModelType>> GetAsyncListFromIEnumerable(
List<MyModelIEnumerableType> mylist,
DateTime startDate,
DateTime endDate)
{
var result = from e in mylist
where e.StartDate >= startDate
&& e.EndDate <= endDate
select new MyModelIEnumerableType
{
// Set of the properties here
};
return await result.AsQueryable().ToListAsync();
}
Run Code Online (Sandbox Code Playgroud)
归档时间: |
|
查看次数: |
4195 次 |
最近记录: |