zoukankan      html  css  js  c++  java
  • ConcurrentBag同线程元素的添加和删除

    https://www.mgenware.com/blog/?p=232

    ConcurrentBag<T>对于同一个线程值的添加和删除是非常快的,因为ConcurrentBag内部将数据按线程的标识而独立存储,所以一个线程从自己的数据中移除一个数据是非常快的,当然如果这个线程中没有数据,那么只能从其他线程中移除数据,此时会发生一些性能损耗从而确保线程安全!
    
     
    
    比如从线程1中加入两个数据,在线程2中加入一个数据。那么当线程2调用TryTake时,被移除的数据肯定是线程2加入的那个数据:
    
    //+ using System.Threading.Tasks;
    //+ using System.Collections.Concurrent;
    
    var bag = new ConcurrentBag<string>();
    
    var t1 = Task.Factory.StartNew(() =>
        {
            bag.Add("线程1: 1");
            Thread.Sleep(1000);
            bag.Add("线程1: 2");
    
            foreach (var str in bag)
                Console.WriteLine(str);
        });
    
    var t2 = Task.Factory.StartNew(() =>
        {
            bag.Add("线程2: 1");
            Thread.Sleep(2000);
    
            string str;
            bag.TryTake(out str);
            Console.WriteLine("线程2取出:" + str);
        });
    
    Task.WaitAll(t1, t2);
     
    
    输出:
    
    线程1: 2
    线程1: 1
    线程2: 1
    线程2取出:线程2: 1
     
    
    如果在线程2(代码中的t2 Task)去掉往ConcurrentBag中添加数据的代码,那么ConcurrentBag将会从线程1的数据中删除一项元素。示例输出:
    
    线程1: 2
    线程1: 1
    线程2取出:线程1: 1

    ConcurrentBag<T>对于同一个线程值的添加和删除是非常快的,因为ConcurrentBag内部将数据按线程的标识而独立存储,所以一个线程从自己的数据中移除一个数据是非常快的,当然如果这个线程中没有数据,那么只能从其他线程中移除数据,此时会发生一些性能损耗从而确保线程安全!

     

    比如从线程1中加入两个数据,在线程2中加入一个数据。那么当线程2调用TryTake时,被移除的数据肯定是线程2加入的那个数据:

    //+ using System.Threading.Tasks;
    //+ using System.Collections.Concurrent;

    var bag =newConcurrentBag<string>();

    var t1 =Task.Factory.StartNew(() =>
    {
    bag.Add("线程1: 1");
    Thread.Sleep(1000);
    bag.Add("线程1: 2");

    foreach (var str in bag)
    Console.WriteLine(str);
    });

    var t2 =Task.Factory.StartNew(() =>
    {
    bag.Add("线程2: 1");
    Thread.Sleep(2000);

    string str;
    bag.TryTake(out str);
    Console.WriteLine("线程2取出:"+ str);
    });

    Task.WaitAll(t1, t2);

     

    输出:

    线程1: 2
    线程1: 1
    线程2: 1
    线程2取出:线程2: 1

     

    如果在线程2(代码中的t2 Task)去掉往ConcurrentBag中添加数据的代码,那么ConcurrentBag将会从线程1的数据中删除一项元素。示例输出:

    线程1: 2
    线程1: 1
    线程2取出:线程1: 1
  • 相关阅读:
    linux查看文件有多少行(WC)
    MYSQL -- 联合索引
    MySQL -- 调优
    MySQL
    Linux命令执行的屏幕输出内容重定向到日志文件
    golang日期时间格式format()
    scp遇到路径中有空格
    查看服务器的网络吞吐
    SQL中关于where后面不能放聚合函数(如sum等)的解决办法
    gearman kubernetes 运行
  • 原文地址:https://www.cnblogs.com/shy1766IT/p/7118801.html
Copyright © 2011-2022 走看看