.NET进阶篇06-async异步、thread多线程2

知识须要不断积累、总结和沉淀,思考和写做是成长的催化剂web

内容目录

1、线程Thread
一、生命周期
二、后台线程
三、静态方法
1.线程本地存储
2.内存栅栏
四、返回值
2、线程池ThreadPool
一、工做队列
二、工做线程和IO线程
三、和Thread区别
四、定时器

1、线程Thread

.NET中线程操做封装为了Thread类,可让开发者对线程进行直观操做。Thread提供了实例方法用于管理线程的生命周期和静态方法用于控制线程的一些访问存储等一些外在的属性,至关于工做空间环境变量了网络

一、生命周期

线程的生命周期有建立、启动、可能挂起、等待、恢复、异常、而后结束。用Thread类能够容易控制一个线程的全生命周期多线程

Thread类的构造函数重载能够接受ThreadStart无参数和ParameterizedThreadStart有参数的委托,而后调用实例的Start()方法启动线程。Thread的构造函数的带有参数的委托,参数是一个object类型,由于咱们能够传入任何信息app

Thread t1 = new Thread(() => {Console.WriteLine($"新线程  {Thread.CurrentThread.ManagedThreadId.ToString("00")}");
});
t1.Start();
Thread t2 = new Thread((obj) => {Console.WriteLine($"新线程  {Thread.CurrentThread.ManagedThreadId.ToString("00")},参数 {obj.ToString()}");
});
t2.Start("hello kitty");

线程启动后,能够调用线程的Suspend()挂起线程,线程就会处于休眠状态(不继续执行线程内代码),调用Resume()唤醒线程,还有一个不太建议使用的Abort()经过抛出异常的方式来销毁线程,随后线程的状态就会变为AbortRequested框架

经常使用的还有线程的等待,在主线程上启用工做线程后,有时须要等待工做线程的完成后,主线程才继续工做。能够调用实例方法Join(),固然咱们能够传入时间参数来代表我主线程最多等你多久异步

二、后台线程

上一章咱们知道Thread默认建立的是前台线程,前台线程会阻止系统进程的退出,就是启动以后必定要完成任务的后台线程会伴随着进程的退出而退出。经过设置属性IsBackground=true改成后台线程。另外还能够经过设置Priority指定线程的优先级。但这个并不总会如你所想设置了高优先级就必定最早执行。操做系统会优化调度,这也是线程不太好控制的缘由之一函数

三、静态方法

上面介绍的都是Tread的实例方法,Thread还有一些经常使用静态方法。有时线程设置不当,会有些意想不到的的bug性能

1.线程本地存储

AllocateDataSlot和AllocateNamedDataSlot用于给全部线程分配一个数据槽。像下面例子所示,若是不在子线程中给数据槽中放入数据,是获取不到其余线程往里面放的数据。测试

var slot= Thread.AllocateNamedDataSlot("testSlot");
//Thread.FreeNamedDataSlot("testSlot");
Thread.SetData(slot, "hello kitty");
Thread t1 = new Thread(() => {//Thread.SetData(slot, "hello kitty");var obj = Thread.GetData(slot);Console.WriteLine($"子线程:{obj}");//obj没有值
});
t1.Start();var obj2 = Thread.GetData(slot);
Console.WriteLine($"主线程:{obj2}");

在声明数据槽的时候.NET提醒咱们若是要更好的性能,请使用ThreadStaticAttribute标记字段。什么意思?咱们来看下面这个例子

//
// 摘要:
//     在全部线程上分配未命名的数据槽。 为了得到更好的性能,请改用以 System.ThreadStaticAttribute 特性标记的字段。
//
// 返回结果:
//     全部线程上已分配的命名数据槽。
public static LocalDataStoreSlot AllocateDataSlot();

例子中的若是不在静态字段上标记ThreadStatic输出结果就会一致。ThreadStatic标记指示各线程的静态字段值是否惟一

[ThreadStatic]
static string name = string.Empty;
public void Function()
{name = "kitty";Thread t1 = new Thread(() => {Console.WriteLine($"子线程:{name}");//输出空});t1.Start();Console.WriteLine($"主线程:{name}");//输出kitty
}

还有一个ThreadLocal提供线程数据的本地存储,用法和上面同样,在每一个线程中声明数据仅供本身使用

ThreadLocal<string> local = new ThreadLocal<string>() { };
local.Value = "hello kitty";
Thread t = new Thread(() => {Console.WriteLine($"子线程:{local.Value}");
});
t.Start();
Console.WriteLine($"主线程:{local.Value}");

上面的静态方法用于线程的本地存储TLS(Thread Local Storage),Thread.Sleep方法在开发调试时也是常常用的,让线程挂起指定的时间来模拟耗时操做

2.内存栅栏

先说一个常识问题,为何咱们发布版本时候要用Release发布?Release更小更快,作了不少优化,但优化对咱们是透明的(计算机里透明认为是个黑盒子,内部逻辑细节对咱们不开放,和生活中透明意味着彻底掌握了解不欺瞒恰好相反),通常优化不会影响程序的运行,咱们先借用网上的一个例子

bool isStop = false;
Thread t = new Thread(() => {bool isSuccess = false;while (!isStop){isSuccess = !isStop;}
});
t.Start();
Thread.Sleep(1000);
isStop = true;
t.Join();
Console.WriteLine("主线程执行结束");

上面例子若是在debug下能正确执行完直到输出“主程序执行结束”,然而在release下却一直会等待子线程的完成。这里子线程中isStop一直为false。首先这是一个由多线程共享变量引发的问题,因此咱们建议最好的解决办法就是尽可能不共享变量,其次可使用Thread.MemoryBarrier和VolatileRead/Write以及其余锁机制牺牲一点性能来换取数据的安全。(上面例子测试若是在子线程while中进行Console.writeLine操做,奇怪的发现release下也能正常输出了,猜想应该是进行了内存数据的更新)

release优化会将t线程中的isStop变量的值加载到CPU Cache中,而主线程修改了isStop值在内存中,因此子线程拿不到更新后的值,形成数据不一致。那么解决办法就是取值时从内存中获取。Thread.MemoryBarrier()就可让在此方法以前的内存写入都及时的从CPU Cache中更新到内存中,在此以后的内存读取都要从内存中获取,而不是CPU Cache。在例子中的while内增长Thread.MemoryBarrier()就能避免数据不一致问题。VolatileRead/Write是对MemoryBarrier的分开解释,从处理器读取,从处理器写入。

四、返回值

前面声明线程时,能够传递参数,那么想要有返回值该如何去作呢?Thread并无提供返回值的操做,后面.NET给出的对Thead的高级封装给出了解决方案,直接使用便可。那目前咱们使用thread类就要本身实现下带有返回值的线程操做,都是经过委托实现的,这里简单介绍一种,(共享外部变量也是能够,不建议)

private Func<T> ThreadWithReturn<T>(Func<T> func)
{T t = default(T);Thread thread = new Thread(() =>{t = func.Invoke();});thread.Start();return () =>{thread.Join();return t;};
}
//调用
Func<int> func = this.ThreadWithReturn<int>(() =>
{Thread.Sleep(2000);return DateTime.Now.Millisecond;
});
int iResult = func.Invoke();

2、线程池ThreadPool

.NET起初提供Thread线程类,功能很丰富,API也不少,因此使用起来比较困难,何况线程还不都是很像理想中运行,因此从2.0开始提供了ThreadPool线程池静态类,全是静态方法,隐藏了诸多Thread的接口,让线程使用起来更轻松。线程池可用于执行任务、发送工做项、处理异步 I/O、表明其余线程等待以及处理计时器

一、工做队列

经常使用ThreadPool线程池静态方法QueueUserWorkItem用于将方法排入线程池队列中执行,若是线程池中有闲置线程就会执行,QueueUserWorkItem方法的参数能够指定一个回调函数委托而且传入参数,像下面这样

ThreadPool.QueueUserWorkItem((obj) => {Console.WriteLine($"线程池中线程  {Thread.CurrentThread.ManagedThreadId.ToString("00")} ,传入 {obj.ToString()}");},"hello kitty");
二、工做线程和IO线程

通常异步任务的执行,不涉及到网络文件等IO操做的,计算密集型,开发者来调用。而IO线程通常用在文件网络上,是CLR调用的,开发者无需管。工做线程发起文件访问调用,由驱动器完成后通知IO线程,IO线程则执行异步任务的回调函数

获取和设置最小最大的工做线程和IO线程

ThreadPool.GetMaxThreads(out int workerThreads, out int completionPortThreads);
ThreadPool.GetMinThreads(out int workerThreads, out int completionPortThreads);
ThreadPool.SetMaxThreads(16, 16);
ThreadPool.SetMinThreads(8, 8);
三、和Thread区别

若是计算机只有8个核,同时能够有8个任务运行。如今咱们有10个任务须要运行,用Thread就须要建立10个线程,用ThreadPool可能只须要利用8个线程就行,节约了空间和时间。线程池中的线程默认先启动最小线程数量的线程,而后根据须要增减数量。线程池使用起来简单,但也有一些限制,线程池中的线程都是后台线程,不能设置优先级,经常使用于耗时较短的任务。线程池中线程也能够阻塞等待,利用ManualResetEvent去通知,但通常不会使用。

四、定时器

.NET中有不少能够实现定时器的功能,在ThreadPool中,咱们能够利用RegisterWaitForSingleObject来注册一个指定时间的委托等待。像下面这样,将每隔一秒就输出消息

ThreadPool.RegisterWaitForSingleObject(new AutoResetEvent(true), new WaitOrTimerCallback((obj, b) =>
{Console.WriteLine($"obj={obj},tid={Thread.CurrentThread.ManagedThreadId},datetime={DateTime.Now}");
}),"hello kitty",1000,false);

咱们日常见过比较多的仍是timer类,timer类在.net内是好几个地方都有的,在System.Threading、
System.Timer、System.Windows.Form、System.Web.UI等里面都有Timer,后面都是在第一个System.Threading里的Timer扩展

System.Threading.Timer timer = new System.Threading.Timer((obj) =>
{Console.WriteLine($"obj={obj},tid={Thread.CurrentThread.ManagedThreadId},datetime={DateTime.Now}");
},"hello kitty",1000,1000);

timer的底层有一个TimerQueue,利用ThreadPool.UnsafeQueueUserWorkItem来完成定时功能,和上面咱们使用的ThreadPool定时器有一点区别

实际开发中,简单定时timer就够用,但通常业务场景比较复杂,须要定制个性化的定时器,好比每个月几号执行,每个月第几个星期几,几点执行,工做日执行等。所以咱们使用Quarz.NET定时框架,后面框架整合时会用到,用起来也是很简单的

先就啰嗦这两点吧,下一篇应该是Task、Parallel以及Async/Await,而后总结介绍下C#的线程模式、线程同步锁机制、异常处理,线程取消,线程安全集合和常见的线程问题

天长水阔,见字如面,随缘更新,拜了个拜~

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/312556.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

概率的 50 个具有挑战性的问题 [8/50]:完美的桥牌

一、说明 我最近对与概率有关的问题产生了兴趣。我偶然读到了弗雷德里克莫斯特勒&#xff08;Frederick Mosteller&#xff09;的《概率论中的五十个具有挑战性的问题与解决方案》&#xff09;一书。我认为创建一个系列来讨论这些可能作为面试问题出现的迷人问题会很有趣。每篇…

【Redis-03】Redis数据结构与对象原理 -下篇

承接上篇【Redis-02】Redis数据结构与对象原理 -上篇 8. type-字符串string 8.1 字符串的三种encoding编码&#xff08;int embstr raw&#xff09; 如果保存的是整型&#xff0c;并且可以用long类型标识&#xff08;-9223372036854775808到9223372036854775807&#xff09…

怎么挑选猫粮?挑选主食冻干猫粮的步骤

各位铲屎官都知道猫天性是食肉动物&#xff0c;无肉不欢的。而冻干猫粮对于猫咪来说是最好还原猫咪食肉天性的食物&#xff0c;不仅可以当成猫咪的主食&#xff0c;也可以用来给猫咪当成零食&#xff0c;帮助猫咪补充营养。冻干猫粮是经过真空冷冻干燥处理的鲜肉&#xff0c;能…

菜鸟网络Java实习一面面经

自我介绍&#xff0c;做过的项目 巴拉巴拉 你项目中用到redis&#xff0c;可以介绍一下为什么使用它吗&#xff1f; 基于内存操作&#xff0c;内存读写速度快。 支持多种数据类型&#xff0c;包括String、Hash、List、Set、ZSet等。 支持持久化。Redis支持RDB和AOF两种持久…

探索 Vue 异步组件的世界:解锁高效开发的秘密(上)

&#x1f90d; 前端开发工程师&#xff08;主业&#xff09;、技术博主&#xff08;副业&#xff09;、已过CET6 &#x1f368; 阿珊和她的猫_CSDN个人主页 &#x1f560; 牛客高级专题作者、在牛客打造高质量专栏《前端面试必备》 &#x1f35a; 蓝桥云课签约作者、已在蓝桥云…

Vue-Setup

一、setup概述 小小提示&#xff1a;vue3中可以写多个根标签。 Person.vue中内容 <template><div class"person"><h2>姓名&#xff1a;{{name}}</h2><h2>年龄&#xff1a;{{age}}</h2><!--定义了一个事件&#xff0c;点击这…

SpringCloud 和 Linux 八股文第三期五问五答

SpringCloud 和 Linux 八股文第三期五问五答 作者&#xff1a;程序员小白条&#xff0c;个人博客 相信看了本文后&#xff0c;对你的面试是有一定帮助的&#xff01; ⭐点赞⭐收藏⭐不迷路&#xff01;⭐ 1&#xff09;Linux常用命令 2&#xff09;如何查看测试项目的日志 一…

docker搭建minio集群,集群分享文件URL踩坑问题

一、环境准备 3台机器&#xff0c;Ip地址依次为IP1,IP2,IP3二、设置服务器时间同步 Minio集群需要各个节点的时间保持同步&#xff0c;使用NTP作为时间同步服务&#xff0c;这里以Minio-1&#xff08;IP1&#xff09;为上游服务器&#xff0c;其它2个节点为下游服务器&#x…

【YOLO系列】yolo V1 ,V3,V5,V8 解释

文章目录 yolo V1 模型结构图通道数 的 物理意义是什么&#xff1f;输出 7730 怎么理解&#xff1f;YOLO v1 损失函数LOSS yolo V3yolo V5yolo V8 视频来源&#xff1a;https://www.bilibili.com/video/BV13K411t7Zs/ AI视频小助理 一、YOLO系列的目标检测算法&#xff0c;其中…

idea 出现Cannot resolve symbol ‘springframework‘解决方法

Maven手动重新加载 1&#xff09;File–>Invalidate Caches / Restart… 清理缓存&#xff0c;重启idea客户端 2&#xff09;File–>Maven–>Reload project重新从maven中加载工程依赖的组件

zabbix通过自动发现-配置监控项、触发器(小白教程)

自动发现配置参考链接&#xff08;不小白&#xff0c;不友好&#xff09; zabbix-get介绍 1配置 zabbix server&#xff1a;版本7&#xff08;不影响&#xff09;,IP地址&#xff1a;192.168.0.60zabbix agent&#xff1a;版本agent1&#xff08;不影响&#xff09;&#xff…

ES6之Reflect详解

✨ 专栏介绍 在现代Web开发中&#xff0c;JavaScript已经成为了不可或缺的一部分。它不仅可以为网页增加交互性和动态性&#xff0c;还可以在后端开发中使用Node.js构建高效的服务器端应用程序。作为一种灵活且易学的脚本语言&#xff0c;JavaScript具有广泛的应用场景&#x…