线程安全的集合

Posted 2020-11-09 stonewl

今日要闻：特朗普跟金胖子见面了！

线程安全的集合是个什么意思？大概解释一下：就是说多个线程同时操作一个集合，不会导致业务数据错乱就叫线程安全的集合。我们知道集合有很多种，数组，List，Dictionary，HashTable等等，就不一一列举了。今天测试的列子是用了List和ConcurrentQueue(.Net自带线程安全的集合)。

还是老规矩，先来一张效果图：

对着图给大家讲解一下：

首先我实例化了两个集合对象：

List<int> lists = new List<int>();

ConcurrentQueue<int> cq = new ConcurrentQueue<int>();

同时并行往集合中添加10000条数据，结果发现List的元素有丢失的情况发生，但是ConcurrentQueue正常。代码很简单：

List<int> lists = new List<int>();
var result = Parallel.ForEach(Enumerable.Range(1, 10000), (val) => {lists.Add(val); });
if (result.IsCompleted)
{
   Console.WriteLine("多线程操作List元素个数:"+lists.Count);
}
Console.WriteLine("--------------------------");
 ConcurrentQueue<int> cq = new ConcurrentQueue<int>();
var result2 = Parallel.ForEach(Enumerable.Range(1, 10000), (val) => 
{ cq.Enqueue(val); });
int index = 0;
 if (result2.IsCompleted)
{
   Console.WriteLine("多线程操作ConcurrentQueue元素个数:" + cq.Count);
}　

扩展：ConcurrentQueue

     以前一直用List没有接触过ConcurrentQueue，觉得这个类比较有意思，首先这个集合属于线程安全的并且是先进先出（后面会有演示代码）。记得之前有个同学问这个集合没有提供Add()和Remove()，如果我们需要添加元素，我们要是使用它的Enqueue()方法，那如果我们需要移除元素怎么办呢？他提供了一个TryDequeue(out T result),这个方法比较有意思，它的解释是移除并返回第一个元素。讲到这里就和前面说的先进先出是不是有点关系了。

ConcurrentQueue<Person> cqp = new ConcurrentQueue<Person>();
Person p2 = new Person();//定义一个被移除的接受对象
 var result3 = Parallel.ForEach(Enumerable.Range(1, 10), (val) =>
{

   Person p = new Person();
   p.Name = "张三" + val;
   p.Age = val;
   p.Sex = "女";
   cqp.Enqueue(p);
});
if (result3.IsCompleted)
 {
      bool a= cqp.TryDequeue(out p2);
      if (a)
      {
         Console.WriteLine("被移除的元素name属性："+p2.Name);
          Console.WriteLine("移除后的元素个数：" + cqp.Count);
       }

}

TryPeek(out T result)是他的另一个方法。只返回不移除。好啦！留个笔录！