标签:数组 let list count 等等 lis 返回 ict --
今日要闻:特朗普跟金胖子见面了!
线程安全的集合是个什么意思?大概解释一下:就是说多个线程同时操作一个集合,不会导致业务数据错乱就叫线程安全的集合。我们知道集合有很多种,数组,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)是他的另一个方法。只返回不移除。好啦!留个笔录!
标签:数组 let list count 等等 lis 返回 ict --
原文地址:https://www.cnblogs.com/stoneWl/p/9099551.html