C#线程安全使用(二)-阿里云开发者社区

开发者社区> kiba518> 正文

C#线程安全使用(二)

简介: 刚才想了半天文章应该起什么名字,最后决定起名为《线程安全使用》,线程安全这个词很难理解,感觉就像托管这词一样,但是托管翻译成英文是managed,我通常把他翻译成被管理,这样就好理解多了,线程安全也是一样,可以理解为可以被多个线程同时使用的集合,而且同时使用的时候是该集合的值是准确的。
+关注继续查看

刚才想了半天文章应该起什么名字,最后决定起名为《线程安全使用》,线程安全这个词很难理解,感觉就像托管这词一样,但是托管翻译成英文是managed,我通常把他翻译成被管理,这样就好理解多了,线程安全也是一样,可以理解为可以被多个线程同时使用的集合,而且同时使用的时候是该集合的值是准确的。

MSDN将在System.Collections.Concurrent命名空间下的集合,都称为线程安全的集合。

下面举一个使用线程安全集合的例子,使用的是BlockingCollection,个人觉得这个集合是够用了,其他集合和这个集合基本上大同小异,没什么大区别。但是根据官方解释ConcurrentBag是适用于快速删除和添加,具体为什么他适用,而BlockingCollection不适用,我也没找到原因。

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace ParallelConsole
{
    class Program
    {
        
        //定义集合大小为51个,也可以不定义大小
        static BlockingCollection<int> blocking = new BlockingCollection<int>(51);
      
        static void Main(string[] args)
        {
            

            blocking = new BlockingCollection<int>();
            Console.WriteLine("当前blocking为:" + blocking.IsCompleted + "设置了集合大小count一样是0,blocking.Count:" + blocking.Count());
            //当前线程标识
            Console.WriteLine(Thread.CurrentThread.GetHashCode());

            for (int i = 0; i < 3; i++)
            {
                ////如果添加到第3个,就设置添加完成,这时在添加就会抛异常
                //if (i == 3)
                //{
                //    blocking.CompleteAdding();
                //}
              
                Action<object> action = new Action<object>(run);
                Task task = new Task(action,i); 
                task.RunSynchronously(); 
            }
            Console.WriteLine("设置添加完成前:" + blocking.IsAddingCompleted);
            //设置添加完成后
            blocking.CompleteAdding();
            Console.WriteLine("设置添加完成后:" + blocking.IsAddingCompleted);
            #region 同步取 取3个
            //for (int i = 0; i < 3; i++)
            //{
            //    Action actionTake = new Action(take);
            //    actionTake();
            //}
            #endregion
            //并发读取
            
            #region 并发步取 取3个
            //blocking.IsCompleted 只有当集合被添加进内容,然后又都被取光了以后,他才会等于ture,否则都是false
            //当IsCompleted为ture时,就不能再取了否则会抛异常
            
            //同时取,结果是 
            //blocking:0
            //blocking:2
            //blocking:1
            if (!blocking.IsCompleted)//如果集合没取光
            {
                Action actionTake2 = new Action(take);
                Parallel.Invoke(actionTake2, actionTake2, actionTake2);
            }
            #endregion

            Console.WriteLine("当前blocking为:" + blocking.IsCompleted +  ",blocking数量为:" + blocking.Count());
            //数据被取光了以后, blocking.Count()为0
            Console.Read();
        }

        public static void take()
        {
            //同步取,blocking.Count()会真实的表现,而异步取,Count是不准确的,因为我取count的时候,可能集合已经又被取出数据了,测试10次肯定会出现不真实的情况
            Console.WriteLine("blocking:" + blocking.Take() + ",blocking数量为:" + blocking.Count());
        }
        public static void run(object i)
        {
            int currentI = int.Parse(i.ToString());
            blocking.TryAdd(currentI); 
        }
    }
}
View Code

解释几个方法:

 Parallel.Invoke(),并发调用ACtion,可以传多个action,也可以传一个action数据组。

 Task(action<t>,object),这是Task的构造方法,接受action,注意object是action的参数,但是解释中并没有说的很明白。(翻译坑,你懂的),根据MSDN提供的构造方法,并没有接受action<t,t>,action<t,t,t>这样的,也就是说,定义函数时,要传递一个实体,而不要传递多个参数,否则任务调用不了。

 task.RunSynchronously(),根据MSDN解释,他是同步运行任务计划用的,同时他和task.Start()一样,也可以启动线程。

BlockingCollection集合

属性一:IsCompleted,他是表示集合是否有数据,只有当集合被添加进内容,然后又都被取光了以后,他才会等于ture,否则都是false。

PS:这个解释如果你要看MSDN一辈子都想不明白,msdn的中文翻译真心坑。

属性一:BlockingCollection.IsAddingCompleted,表示是否添加完成。针对blocking.CompleteAdding()的使用,当调用了该方法IsAddingCompleted就为true。

方法一:BlockingCollection.blocking.CompleteAdding(),设置IsAddingCompleted用的。

方法二:BlockingCollection.Add,添加一个实体

方法三:BlockingCollection.TryAdd,添加一个实体,我这里用的是这个方法,区别是,如果添加重复项,他会引发InvalidOperationException这个异常。

方法四:BlockingCollection.Take,从集合中取一个值,注意,是真的取出来,取出来后,BlockingCollection.cout会减一。

运行结果如下:

今天先写到这,写文字还真是累,明明没写几个字。。。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
什么是线程安全
什么是线程安全?         如果你的代码所在的进程中有多个线程在同时运行,而这些线程可能会同时运行这段代码。如果每次运行结果和单线程运行的结果是一样的,而且其他的变量的值也和预期的是一样的,就是线程安全的。
685 0
iOS开发中 关于阿里云服务器的使用与安全策略 韩俊强的博客
使用背景:         云服务已经很多年了,早期没能加入使用云大军中的一员,后来后悔莫及。2015年记得当时没办法租用的虚拟主机三天两天挂了,导致我认认真真的考虑了一次,觉得还是要使用云服务器! 从免费的主机屋学习版到各种虚拟机的实验,再到之前是用300元左右买的别人的虚拟主机,空间有几G,感觉还行,正好又值他们搞活动,买两年送一年!预存还有返还!心动了,就没有任何考虑就预存了一千块! 开始的几个月感觉还行,速度什么的还过得去,就没去管网站的事了。
1384 0
java安全编码指南之:线程安全规则
如果我们在多线程中引入了共享变量,那么我们就需要考虑一下多线程下线程安全的问题了。那么我们在编写代码的过程中,需要注意哪些线程安全的问题呢?
2646 0
使用企业安全组导致自建SNAT网关网络不通
使用企业安全组导致自建SNAT网关网络不通
174 0
Servlet中的线程安全
        Servlet 之所有效率比CGI高,是因为CGI每一个请求都会FORK出一个进程来处理相应的请求,而Servlet则是用线程来处理的,但随之而来就有一个问题:多线程的安全问题!       在Servlet中,类的成员变量是共享的,所有的请求都共用成员变量,为了保证线程安全,我们应该尽量做到如下几点:      1.用方法变量,即局部变量来保存请求中的专有数据,因为每个线程都会有自己的一份局部变量,这样就不会相互影响了。
726 0
C#多线程编程系列(四)- 使用线程池
原文:C#多线程编程系列(四)- 使用线程池 目录 1.1 简介 1.2 在线程池中调用委托 1.3 向线程池中放入异步操作 1.4 线程池与并行度 1.5 实现一个取消选项 1.6 在线程池中使用等待事件处理器及超时 1.7 使用计时器 1.8 使用BackgroundWorker组件 参考书籍 笔者水平有限,如果错误欢迎各位批评指正! 1.1 简介 在本章中,主要介绍线程池(ThreadPool)的使用;在C#中它叫System.Threading.ThreadPool,在使用线程池之前首先我们得明白一个问题,那就是为什么要使用线程池。
846 0
+关注
kiba518
天下多少有情事,满眼尽是无奈人。
34
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《Nacos架构&原理》
立即下载
《看见新力量:二》电子书
立即下载
云上自动化运维(CloudOps)白皮书
立即下载