.NET进阶篇06-async异步、thread多线程4_concurrentdictionary 异步 net

.NET进阶篇06-async异步、thread多线程4
知识需要不断积累、总结和沉淀，思考和写作是成长的催化剂

一、锁

1、lock

2、Interlocked

3、Monitor

4、SpinLock

5、Mutex

6、Semaphore

7、Events

1、AutoResetEvent

2、ManualResetEvent

3、ManualResetEventSlim

8、ReaderWriterLock

二、线程安全集合

三、多线程模型

1、同步编程模型SPM

2、异步编程模型APM

3、基于事件编程模型EAP

4、基于任务编程模型TAP

四、End

一、锁
数据库中也有锁概念，行锁，表锁，事物锁等，锁的作用就是控制并发情况下数据的安全一致，使一个数据被操作时，其他并发线程等待。开发方面多线程并行编程访问共享数据时，为保证数据的一致安全，有时需要使用锁来锁定对象来达到同步

.NET中提供很多线程同步技术。
有lock，Interlocked，Monitor等用于进程内同步锁，
Mutex互斥锁，Semaphore信号量，Events，ReaderWriterLockSlim读写锁等用于多个进程间的线程同步

1、lock
lock语句是设置对锁定和解除锁定的一种简单方式，也是最常用的一种同步方式。lock用于锁定一个引用类型字段，当线程执行到Lock处，会锁定该字段，使之只有一个线程进入lock语句块内，才lock语句结束位置再释放锁定，另一个线程才可以进入。原理运用同步块索引，感兴趣可以研究下

lock (obj)
{
    //synchronized region
}
1
2
3
4

因为只有一个线程可以进去，没有并发，所以牺牲了性能，所以要尽量缩小lock的范围，另一个建议是首选锁一个私有变量，也就是SyncRoot模式，声明一个syncRoot的私有object变量来进行锁定，而不是使用lock(this)，因为外面调用者也可能锁定你这个对象的实例，但他并不知道你内部也使用了锁，所以容易造成死锁

private object syscRoot = new object();
public void DoThis()
{
    lock (syscRoot)
    {
        //同一个时间只有一个线程能到达这里
    }
}
1
2
3
4
5
6
7
8

2、Interlocked
InterLoacked用于将变量的一些简单操作原子化，也就是线程安全同步。我们常写的i++就不是线程安全的，从内存中取值然后+1然后放回内存中，过程中很可能被其他线程打断，比如在你+1后放回内存时，另一个线程已经先放回去了，也就不同步了。InerLocked类提供了以线程安全的方式递增、递减、交换、读取值的方法
比如以下代替lock的递增方式

int num = 0;
//lock (syscRoot)
//{
//    num++;
//}
num = Interlocked.Increment(ref num);
1
2
3
4
5
6

3、Monitor
上面lock就是Monitor的语法糖，通过编译器编译会生成Monitor的代码，像下面这样

lock (syscRoot)
{
    //synchronized region
}
//上面的lock锁等同于下面Monitor
Monitor.Enter(syscRoot);
try
{
    //synchronized region
}
finally
{
    Monitor.Exit(syscRoot);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

Monitor不同于Lock就是它还可以设置超时时间，不会无限制的等待下去。

bool lockTaken = false;
Monitor.TryEnter(syscRoot,500,ref lockTaken);
if (lockTaken)
{
    try
    {
        //synchronized region
    }
    finally
    {
        Monitor.Exit(syscRoot);
    }
}
else
{
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

4、SpinLock
SpinLock自旋锁是一种用户模式锁。对了，插一嘴锁分为内核模式锁和用户模式锁，内核模式就是在系统级别让线程中断，收到信号时再切回来继续干活，用户模式就是通过一些cpu指定或则死循环让线程一直运行着直到可用。各有优缺点吧，内核Cpu资源利用率高，但切换损耗，用户模式就相反，如果锁定时间较长，就会白白循环等待，后面就有混合模式锁的出现了

如果有大量的锁定，且锁定时间非常短，SpinLock就很有用，用法和Monitor类似，Enter或TryEnter获取锁，Exit释放锁。IsHeld和IsHeldByCurrentThread指定它当前是否锁定

另外SpinLock是个结构类型，所以注意拷贝赋值时会创建全新副本问题。必要时可按引用来传递

5、Mutex
Mutex互斥锁提供跨多个进程同步一个类，定义互斥锁的时候可以指定互斥锁的名称，这样系统能够识别，所以在另一个进程中定义的互斥，其他进程也是可以访问到的，Mutex.OpenExisting()便可以得到。

bool createdNew = false;
Mutex mutex = new Mutex(false, "ProCharpMutex", out createdNew);
if (mutex.WaitOne())
{
    try
    {
        //synchronized region
    }
    finally
    {
        mutex.ReleaseMutex();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13

介于此我们可以用来禁止一个应用程序启动两次，一般我们通过进程的名称来判断，这里我们使用Mutex实现

bool createdNew = false;
Mutex mutex = new Mutex(false, "SingletonWinAppMutex", out createdNew);
if (!createdNew)
{
    MessageBox.Show("应用程序已经启动过了");
    Application.Exit();
    return;
}
1
2
3
4
5
6
7
8

6、Semaphore
Semaphore信号量和互斥类似，区别是，信号量可以同时让多个线程使用，是一种计数的互斥锁定。通过计数允许同时有几个线程访问受保护的资源。也可以指定信号量名称以使在多个进程间共享

Semaphore和上面Mutex都是继承自WaitHandle基类，WaitHandle用于等待一个信号的设置，嗲用Wait，线程会等待接收一个与等待句柄相关的信号

SemaphoreSlim是对Semaphore的轻量替代版本(它不继承WaitHandle)，SemaphoreSlim(int initialCount, int maxCount)构造函数可指定最大并发个数，然后在线程内通过SemaphoreSlim的Wait等到直到来接收信号是否可以进去受保护代码块了，最后记得要Release，不然下一个线程获取不到准许进入的信号

7、Events
Events事件锁不同于委托中的事件，在System.Threading命名空间下，用于系统范围内的事件资源的同步。

有AutoResetEvent自动事件锁、
ManualResetEvent手动事件锁、
以及轻量版本ManualResetEventSlim
1
2
3

1、AutoResetEvent
AutoResetEvent也是继承自waitHandle类的，也是通过WaitOne来等待直到有信号，
它有两种状态：终止和非终止，可以调用set和reset方法使对象进入终止和非终止状态。
通俗点就是set有信号，另一个线程可以进入了，reset非终止无信息，其他线程就阻塞了。
自动的意思就是一个线程进入了，自动Reset设置无信号了其他线程就进不去了。
类似现实中的汽车收费口，一杆一车模式。

private AutoResetEvent autoEvent = new AutoResetEvent(false);
public void DoThis()
{
    autoEvent.WaitOne();
    //执行同步代码块
    autoEvent.Set();
}
1
2
3
4
5
6
7

2、ManualResetEvent
手动事件锁和自动的区别在于，手动事件锁没有信号时会阻塞一批线程的，有信号时，所有线程都运行，同时唤醒多个线程，除非手动Reset再阻塞，类似现实场景中火车道路口的栅栏，落杆拦截一批人，起杆则一批人蜂拥通过，用法和上面一样，WaitOne等待信号，结束时通过Set来通知有信号了，可以通过了

3、ManualResetEventSlim
ManualResetEventSlim通过封装 ManualResetEvent提供了自旋等待和内核等待的混合锁模式。如果需要跨进程或者跨AppDomain的同步，那么就必须使用ManualResetEvent。ManualResetEventSlim使用Wait来阻塞线程，支持任务的取消。和SemaphoreSlim的Wait一样，内部先通过用户模式自旋然后再通过内核模式效率更高。

8、ReaderWriterLock
ReaderWriterLock读写锁不是从限定线程个数的角度来保护资源，而是按读写角度来区分，就是你可以锁定当某一类线程（写线程）中一个进入受保护资源时，另一类线程（读线程）全部阻塞。如果没有写入线程锁定资源，就允许多个读取线程方法资源，但只能有一个写入线程锁定该资源

具体用法参考示例

// 创建读写锁

ReaderWriterLock rwLock = new ReaderWriterLock();
// 当前线程获取读锁，参数为：超时值（毫秒）
rwLock.AcquireReaderLock(250);
// 判断当前线程是否持有读锁
if (!rwLock.IsReaderLockHeld)
{
    return;
}
Console.WriteLine("拿到了读锁......");
// 将读锁升级为写锁，锁参数为：超时值（毫秒）
LockCookie cookie = rwLock.UpgradeToWriterLock(250);
// 判断当前线程是否持有写锁
if (rwLock.IsWriterLockHeld)
{
    Console.WriteLine("升级到了写锁......");
    // 将锁还原到之前所的级别，也就是读锁
    rwLock.DowngradeFromWriterLock(ref cookie);
}
// 释放读锁（减少锁计数，直到计数达到零时，锁被释放）
rwLock.ReleaseReaderLock();
Console.WriteLine("顺利执行完毕......");

// 当前线程获取写锁，参数为：超时值（毫秒）
rwLock.AcquireWriterLock(250);
// 判断当前线程是否持有写锁
if (rwLock.IsWriterLockHeld)
{
    Console.WriteLine("拿到了写锁......");
    // 释放写锁（将减少写锁计数，直到计数变为零，释放锁）
    rwLock.ReleaseWriterLock();
}
// 释放写锁（将减少写锁计数，直到计数变为零，释放锁）
// 当前线程不持有锁，会抛出异常
rwLock.ReleaseWriterLock();
Console.WriteLine("顺利执行完毕......");
Console.ReadLine();
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

ReaderWriterLockSlim同样是ReaderWriterLock的轻量优化版本，简化了递归、升级和降级锁定状态的规则。

1. EnterWriteLock 进入写模式锁定状态
2. EnterReadLock 进入读模式锁定状态
3. EnterUpgradeableReadLock 进入可升级的读模式锁定状态
   并且三种锁定模式都有超时机制、对应 Try… 方法，退出相应的模式则使用 Exit… 方法，而且所有的方法都必须是成对出现的

二、线程安全集合
并行环境下修改共享变量为了保证资源安全，通常使用上面介绍的锁或信号量来解决此问题。其实.NET也内置了一些线程安全的集合，使用他们就像使用单线程集合一样。

类型 描述

BlockingCollection 提供针对实现 IProducerConsumerCollection 的任何类型的限制和阻塞功能。
有关详细信息，请参阅BlockingCollection 概述。 ConcurrentDictionary<tkey,tvalue
style=“font-size: inherit; color: inherit; line-height: inherit;
margin: 0px; padding: 0px;”> 键/值对字典的线程安全实现。
ConcurrentQueue FIFO（先进先出）队列的线程安全实现。
ConcurrentStack LIFO（后进先出）堆栈的线程安全实现。 ConcurrentBag 无序的元素集合的线程安全实现。
IProducerConsumerCollection 类型必须实现以在 BlockingCollection 中使用的接口。

三、多线程模型
1、同步编程模型SPM
2、异步编程模型APM
我们常见的XXBegin， XXEnd这两个经典的配对方法就是异步的，Begin后会委托给线程池调用一个线程去执行。还有委托的BeginInvoke调用

FileStream fs = new FileStream("D:\\test.txt", FileMode.Open);
var bytes = new byte[fs.Length];
fs.BeginRead(bytes, 0, bytes.Length, (aysc) =>
{
    var num = fs.EndRead(aysc);
}, string.Empty);
1
2
3
4
5
6

3、基于事件编程模型EAP
WinFrom/WPF开发中的BackgroundWorker类就是异步事件模式的一种实现方案，RunWorkerAsync方法启动与DoWork事件异步关联的方法，工作完成后，就触发RunWorkerCompleted事件，也支持CancelAysnc方法取消以及ReportProgress通知进度等。还又一个典型的就是WebClient

WebClient client = new WebClient();
client.DownloadDataCompleted += (sender,e)=> 
{
};
client.DownloadDataAsync(new Uri("https://www.baidu.com/"));
1
2
3
4
5

4、基于任务编程模型TAP
Task出来后，微软就大力推广基于Task的异步编程模型，APM和EAP都被包装成Task使用。下面示例简单用Task封装上面的编程模型。WebClient的DownloadDataTaskAsync实现和示例中的类似，利用一个TaskCompletionSource包装器包装成Task

FileStream fs = new FileStream("D:\\test.txt", FileMode.Open);
var bytes = new byte[fs.Length];
var task = Task.Factory.FromAsync(fs.BeginRead, fs.EndRead, bytes, 0, bytes.Length, string.Empty);
var nums = task.Result;

Action action = () =>{ };
var task = Task.Factory.FromAsync(action.BeginInvoke, action.EndInvoke, string.Empty);

public static Task<int> GetTaskAsuc(string url)
{
    TaskCompletionSource<int> source = new TaskCompletionSource<int>();//包装器
    WebClient client = new WebClient();
    client.DownloadDataCompleted += (sender, e) =>
    {
        try
        {
            source.TrySetResult(e.Result.Length);
        }
        catch (Exception ex)
        {
            source.TrySetException(ex);
        }
    };
    client.DownloadDataAsync(new Uri(url));
    return source.Task;
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

四、End
最近几篇介绍了如何编写多线程和多任务应用程序。在应用程序开发过程中要仔细规划，太多的线程导致资源问题，太少则起不到大效果。多线程编程中一个中肯的建议就是
尽量避免修改共享变量，使同步的要求变低。通过合理规划可以减少大部分的同步复杂度。

Search the fucking web
Read the fucking maunal

——GoodGoodStudy