.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#的线程模式、线程同步锁机制、异常处理，线程取消，线程安全集合和常见的线程问题

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