【C#】【笔记】Task.Factory.StartNew的相关异常

3、Task.Factory.StartNew将来的任务执行有可能劫持现有任务并杀死其进程.。

a、推荐方法

引入System.Collections.Concurrent 命名空间–线程安全数据结构

把非线程安全的数据结构替换成下面的数据结构即可

BlockingCollection<T> 为实现 IProducerConsumerCollection<T> 的线程安全集合提供阻塞和限制功能。

ConcurrentBag<T> 表示对象的线程安全的无序集合。

ConcurrentDictionary<TKey, TValue> 表示可由多个线程同时访问的键值对的线程安全集合。

ConcurrentQueue<T> 表示线程安全的先进先出 (FIFO) 集合。

ConcurrentStack<T> 表示线程安全的后进先出 (LIFO) 集合。

OrderablePartitioner<TSource> 表示将一个可排序数据源拆分成多个分区的特定方式。

Partitioner 提供针对数组、列表和可枚举项的常见分区策略。

Partitioner<TSource> 表示将一个数据源拆分成多个分区的特定方式。

b、锁方法

对于只需要提前响应，而不需要效率的业务可以在内部加锁。

c、多线程操作会出现线程安全问题，那么可以拆分数据源，然后每一个线程操作单独的某个数据块，多线程操作完毕后，在合并数据。

2、实体可能已被修改或删除异常(20201127)

执行添加日志表数据封装为异步了Task.Factory.StartNew，

先添加日志表，再执行真删除另一张表的数据时，

抛出异常：Store update, insert, or delete statement affected an unexpected number of rows (0). Entities may have been modified or deleted since entities were loaded. See http://go.microsoft.com/fwlink/?LinkId=472540 for information on understanding and handling optimistic concurrency exceptions.

提示数据已经被操作过了，脏数据(仓储判断的是整个数据，不是判断的要操作的这一张表是否脏数据)，当然还有其他多种不能操作数据的异常。

处理，本次添加日志不使用Task，本次日志需要完整记录才不会数据丢失。

1、数据库连接对象断开问题(20200927)

场景：订单生成之后，许多后续操作使用Task.Factory.StartNew进行，例如调用，推荐人所推荐用户下单后，增加其计算优惠券推荐人数量。Task.Factory.StartNew偶尔抛出异常：System.InvalidOperationException: ExecuteReader 要求已打开且可用的 Connection。连接的当前状态为已关闭。

原因：

1、Task.Factory.StartNew中调用的是创建订单线程Order_MainBLL类的属性this.DBSession，去执行业务。也就是使用了同一个数据库连接对象this.DbContext。

2、Task.Factory.StartNew创建了任务，务开始时，原创建订单业务结束时，关闭了数据库连接对象。

处理：

使用不同的数据库连接对象。

var _DBSession= new Order_MainBLL().DBSession;

try

{

_DBSession.IOrder_MainDAL.SetOrderSampleConfirmList(oid,isRepeat:1);

}

catch (Exception ex)

{

LogHelper.Instance.Error("余额支付后生成待确认出错:", ex);

}