走进异步编程的世界--async/await项目使用实战

时间:2023-12-17 17:53:50

起因:今天要做一个定时器任务:五分钟查询一次数据库发现超时未支付的订单数据将其状态改为已经关闭(数据量大约100条的情况)

开始未使用异步:

 public void SelfCloseGpPayOrders()
{
try
{
var list =db.GpPayOrders.Where(a => a.PaymentStatus == ).ToList();
foreach (var item in list)
{
if(item.AddTime.AddHours() < DateTime.Now)
{
item.PaymentStatus = ;
item.Remark = "长时间未支付自行关闭订单";
db.Entry(item).State = EntityState.Modified;
db.SaveChangesAsync();
NLogHelp.WriteInfo("长时间未支付自行关闭订单,订单支付号:"+item.MerOrderId);
}
}
//return "success"; }
catch (Exception)
{
//return e.InnerException.Message;
}
}

执行后发现每次更改两三次就不执行了,应该就是线程阻塞了,所以改成了异步

 public async void SelfCloseGpPayOrders()
{
try
{
var list =await db.GpPayOrders.Where(a => a.PaymentStatus == ).ToListAsync();
foreach (var item in list)
{
if(item.AddTime.AddHours() < DateTime.Now)
{
item.PaymentStatus = ;
item.Remark = "长时间未支付自行关闭订单";
db.Entry(item).State = EntityState.Modified;
await db.SaveChangesAsync();
NLogHelp.WriteInfo("长时间未支付自行关闭订单,订单支付号:"+item.MerOrderId);
}
}
//return "success"; }
catch (Exception)
{
//return e.InnerException.Message;
}
}

修改之后。瞬间几百条数据更改完了,没有遗漏!

附录:

走进异步编程的世界-开始接触async/await