C#教程之C# 多线程学习笔记

当前位置:

首页 > Python基础教程 >

C#教程之C# 多线程学习笔记 - 2

一、同步概要

同步构造基本分为四种，简单的阻塞方法、锁构造、信号构造、非阻塞同步构造。

1.1 阻塞方法

阻塞方法一般是会暂停某些线程的执行，例如 Sleep() 与 Join() 方法。当一个线程被阻塞的时候，会立即出让(yields) CPU 时间片，不再消耗处理器时间。
通过检查线程的 ThreadState 属性来确认某个线程是否被阻塞。
当某个线程被阻塞或者解除阻塞的时候，会进行上下文切换。
阻塞方法在满足以下几个条件的时候会进行解除。
- 阻塞条件满足。
- 操作超时。
- 通过 Thread.Interrupt() 中断。
- 通过 Thread.Abort() 中止。

1.2 阻塞与自旋

信号构造与锁构造可以在某些条件被满足前阻塞线程。另外一种方法就是通过自旋来等待条件被满足。
自旋即通过一个循环不断检测条件，来伪造一个空忙状态。
虽然自旋会造成大量的处理器时间浪费，但是它可以避免上下文切换带来的额外开销。

一个标准的自旋结构如下列代码。

// 单纯的自旋
while(!proceed);
// 阻塞 + 自旋
while(!proceed) Thread.Sleep(10);

二、锁

2.1 排它锁

排它锁的作用是为了保证线程安全，如下列代码。如果 Go() 方法被两个线程同时执行，则可能某个线程在执行完 if 后，另一个线程已经将 V2 置为0，原先线程就可能造成除数不能为 0 的异常。

class Code1
{
    static int V1 = 1,V2 = 1;

    static void Go()
    {
        if(V2 != 0) Console.WriteLine(V1 / V2);
        V2 = 0;
    }
}

// 使用了排它锁的代码
class Code2
{
    static int V1 = 1,V2 = 1;
    static readonly object locker = new object();

    static void Go()
    {
        lock(locker)
        {
            if(V2 != 0) Console.WriteLine(V1 / V2);
             V2 = 0;
        }
    }
}

如果使用了 lock 语句快，则可以锁定一个同步对象，其他竞争锁的线程会被阻塞，直到锁被释放。
如果有多个线程竞争锁，则按照先到先得的队列进行排队，通过排它锁可以强制线程对锁保护的内容进行顺序访问。
在竞争锁时被阻塞的线程，其状态为 WaitSleepJoin 。

不同的同步结构技术的性能开销。

构造	用途	开销
lock （ Monitor.Enter / Monitor.Exit ）	确保同一时间只有一个线程可以访问资源或代码	20 ns
Mutex	确保同一时间只有一个线程可以访问资源或代码	1000 ns
SemaphoreSlim	确保只有不超过指定数量的线程可以并发访问资源或代码	200 ns
Semaphore	确保只有不超过指定数量的线程可以并发访问资源或代码	1000 ns
ReaderWriterLockSlim	允许多个读线程和一个写线程共存	40 ns
ReaderWriterLock (已过时)	允许多个读线程和一个写线程共存	100 ns

2.2 Monitor.Enter 与 Monitor.Exit

lock 语句块实质上就是一个语法糖，其核心代码就是结合 try/finally 来调用 Monitor.Enter() 与 Monitor.Exit() 方法，并且如果在一个方法内直接调用 Monitor.Exit() 会直接抛出异常。
```
Monitor.Enter(locker);
try
{
    if(V2 != 0) Console.Writeline(V1 / V2);
    V2 = 0;
}
finally
{
    Monitor.Exit(locker);
}
```
上述情况可能发生锁泄漏，因为在 Monitor.Enter() 与 try/finally 语句块之间如果发生了异常，会导致后续的 try/finally 语句块不被执行。造成无法获得锁，或者得到锁之后，无法释放造成锁泄漏。

解决锁泄漏的方式是，CLR 4.0 当中，对于 lock 语句的翻译则是通过一个 bool 类型的 lockTaken 进行解决。

bool lockTaken = false;
try
{
    Monitor.Enter (locker, ref lockTaken);
    // 用户代码 ...
}
finally
{
    if(lockTaken)
    {
        Monitor.Exit(locker);
    }
}

Monitor 还提供了 TryEnter() 方法，用于执行超时时间，如果超过时间没有获得到锁，则返回 false 。

2.3 什么时候加锁

需要访问任意可写的共享字段，下面代码展示了线程安全与非线程安全的代码。

class ThreadUnsafe
{
  static int _x;
  static void Increment() { _x++; }
  static void Assign()    { _x = 123; }
}

// 线程安全
class ThreadSafe
{
    static readonly object _locker = new object();
    static int _x;

    static void Increment() { lock(_locker) _X++; }
    static void Assign() { lock(_locker) _x++; }
}

2.4 锁与原子性

如果一组变量总是在一个锁内进行读且，即可被成为原子的读写。
例如 lock(locker) { if(x != 0) y /= x; } 就可以说 x 与 y 是被原子访问的，因为这段代码无法被其他线程分割或者抢占。
如果在 lock 锁内抛出异常，将会影响锁的原子性，这个时候就需要结合回滚机制来进行实现。

2.5 锁嵌套

排他锁是可以被嵌套的，并且只有当最外层的锁被释放的时候，对象才会被解锁。
线程只会在最外层的 lock 语句处被阻塞。

2.6 死锁

死锁是当两个甚至多个线程所等待的资源都被对方占用的时候，它们都无法执行，就会产生了死锁。

一个标准的死锁代码如下，我们在 A 线程内部锁定了 locker1 与 locker2 ，在主线程同同时也锁定了 locker2 与 locker1 。这个时候由于排他锁的特性，主线程与新开启的线程都会等待对方的锁被释放，造成死锁。

object locker1 = new object();
object locker2 = new object();

new Thread(() => {
    lock(locker1)
    {
        Thread.Sleep(1000);
        lock(loekcer2);
    }
}).Start();

lock(locker2)
{
    Thread.Sleep();
    lock(locker1);
}

应该尽量较少对锁的使用，更多的依靠其他的同步构造进行处理。

2.7 互斥体

互斥体使用 WaitOne() 方法进行加锁，使用 ReleaseMutex() 来解锁。
关闭或者销毁 Mutex 对象会自动释放锁，所以可以结合 using 语句块进行使用。
互斥体是机器范围的，其性能比 lock 慢约 50 倍。

2.8 信号量

信号量具有一定容量，当容量满了之后和就会拒绝其他线程占用，当有一个线程释放资源之后，其他线程按先后顺序进入。

class Program
{
 static void Main(string[] args)
 {
     var sem = new Semaphore();

     for (int i = 1; i <= 5; i++) new Thread(sem.Enter).Start(i);
 }
}

public class Semaphore
{
 private readonly SemaphoreSlim _semaphoreSlim = new SemaphoreSlim(3);

 public void Enter(object id)
 {
     Console.WriteLine($"Id 为 {id} 的线程想调用本方法。");
     _semaphoreSlim.Wait();
     Console.WriteLine($"Id 为 {id} 的线程已经进入方法。");
     Thread.Sleep(1000 * (int)id);
     Console.WriteLine($"Id 为 {id} 的线程正在离开方法。");
     _semaphoreSlim.Release();
 }
}

容量为 1 的信号量与 Mutex 和 lock 类似。
信号量是线程无关的，任何线程都可以调用 Release() 方法释放信号量。而 Mutex 与 lock 只有获得锁的线程才可以释放。
在 .NET 4.0 当中有一个轻量级的信号量 SemaphoreSlim ，但是不是跨进程的，开销只有 Semaphore 的四分之一。
一般在某些需要限流或者是要执行比较密集的磁盘 I/O 操作，这个时候可以使用信号量进行并发限制，这样可以改善程序整体的性能。

三、线程安全

如果某个程序或者方法是一个线程安全的，那么它在任意的多线程场景中都不会存在不确定性。
线程安全是通过锁，或者减少线程交互来实现的。
多线程当中的线程安全一般是在需要的时候才会进行实现，但是可以以牺牲粒度，将整段代码甚至是整个对象封装在一个排它锁的内部。这种解决方案十分简单有效，这种方案适用于使用了线程不安全的第三方库代码，并且仅适用于能够快速执行的场景，否则会产生大量阻塞。
除了 CLR 定义的基本类型以外，很少有能够在高并发需求下保证其实例是线程安全的，除了 Concurrent 下的并行集合以外。
可以最小化共享数据来减少线程交互，例如 Web 服务器不需要持久化并发请求的数据，是无状态的，线程交互的时候仅需要考虑静态字段等共享资源。
除了以上两种方法之外，也可以使用自动锁机制，集成 ContextBoundObject 类并且使用 Synchronization 特性。但是这种方法很容易造成死锁的情况，并且降低并发度。

3.1 线程安全与 BCL 类型

通过锁可以将不安全的代码转换为线程安全的代码，例如 BCL 提供的 List<T> 集合本身不是线程安全的，但是通过对一个集合实例的锁定，我们就可以进行线程安全的操作。下面的代码当中，我们直接使用 List<int> 集合自身来加锁，这里对集合进行遍历的操作也不是线程安全的，也需要加锁进行处理，另一种方式就是通过读写锁来实现避免长时间锁定。

    class Program
    {
        static void Main(string[] args)
        {
            var bcl = new BCLThreadSafe();

            for (int i = 0; i < 10; i++)
            {
                new Thread(bcl.AddItem).Start();
            }
        }
    }

    public class BCLThreadSafe
    {
        private readonly List<int> _innerList  = new List<int>();

        public void AddItem()
        {
            lock (_innerList)
            {
                _innerList.Add(_innerList.Count);
            }

            var sb = new StringBuilder();

            lock (_innerList)
            {
                foreach (var item in _innerList)
                {
                    sb.Append(item).Append(',');
                }
            }

            Console.WriteLine(sb.ToString().TrimEnd(','));
        }
    }

即便 List<T> 集合是线程安全的，如果我们需要使用以下代码增加一个新的数据到集合当中。也会由于在执行 if 之后，其他线程抢占修改了 _list 集合，增加了一个相同的类目。在这个时候，对 _list 集合的添加操作就是存在问题的。
```
if(!_list.Contains(newItem)) _list.Add(newItem);
```
在高并发的环境下，对集合的访问加锁可能产生大量阻塞，所以进行类似操作的时候建议使用线程安全的队列、栈、字典。
针对于静态成员，BCL 的所有类型的静态成员都实现了线程安全，所以开发人员在开发基础类型或者框架的时候，应该保证静态成员的线程安全。
大部分 BCL 类型的只读访问都是线程安全的，开发人员在设计类基础类型或者框架的时候也应该遵循这个规则。

3.2 应用服务器其与线程安全

服务端经常需要使用到多线程处理客户请求，也就意味着必须考虑线程安全。但一般来说服务端类都是无状态的，或者为每个请求创建新的对象实例，很少存在有交互的点。

以缓存为例，假设对一个用户表使用了静态的字典实例进行缓存，那么就存在线程安全的问题。下列代码在读取与更新锁的时候，使用了排它锁进行加锁处理。但是会存在两个线程同时访问 GetUser() 方法的时候，都传递了未缓存过得数据的 id ，这个时候就会去查询两次数据库。虽然可以通过对整个 GetUser() 加锁，但是这样设计的话，都会在 QueryUser() 进行查询的时候，整个获得用户信息的方法都被阻塞。

static class UserCache
{
    static Dictionary<int,User> _users = new Dictionary<int,User>();

    internal static User GetUser(int id)
    {
        User u = null;

        lock(_users)
        {
            if(_users.TryGetValue(id,out u))
            {
                return u;
            }
        }

        // 从数据库查询用户数据
        u = QueryUser(id);

        lock(_users)_users[id] = u;
        return u;
    }
}

3.3 WPF 与 WinForm 程序的线程安全

富客户端程序一般都是基于 DependencyObject (WPF) 与 Control (Windows Forms)，它们都具备线程亲和性，即只有创建他们的线程才能够访问其成员。
作用就是访问 UI 对象并不需要加锁，坏处则是如果要跨线程调用 UI 控件则需要一些比较繁琐的步骤。
- WPF：其 Dispatcher 调用 Invoke() 或 BeginInvoke() 。
- Windows Forms：调用 Control() 对象的 Invoke() 或 BeginInvoke() 。

Invoke() 与 BeginInvoke() 都接收一个委托以便代替工作线程需要在 UI 线程执行的操作。前者是同步方法，在委托执行完成之前，都处于阻塞状态。后者是异步方法，调用方立刻返回。

// WPF DEMO
public partial class MainWindow : Window
{
 public MainWindow()
    {
     InitializeComponent();

     new Thread(Work).Start();
    }

    private void Work()
    {
     Thread.Sleep(5000); // 阻塞当前线程 5s 模拟耗时任务
     UpdateMessage("new msg");
    }

    private void UpdateMessage(string msg)
    {
     var action = () => txtMessage.Text = msg;
     Dispatcher.Invoke(action);
    }
}

// Windows Forms DEMO
public partial class FormClass : Form
{
 // ... 其他代码

 private void UpdateMessage(string msg)
    {
     var action = () => txtMessage.Text = msg;
     this.Invoke(action);
    }

 // ... 其他代码
}

3.4 不可变对象

不可变对象拥有的不变性可以在多线程环境中最小化共享可写状态的问题。

四、事件等待句柄与信号同步

事件等待句柄的作用是用于进行信号同步。
信号同步即一个线程进行等待，直到其接受到其他线程通知的过程。

信号构造的开销比较。

构造	用途	开销
AutoResetEvent	使线程在接收到其他线程信号时解除阻塞一次。	1000 ns
ManualResetEvent	使线程在接收到其他线程信号时解除阻塞，并不继续阻塞，直到其复位。	1000 ns
ManualResetEventSlim	使线程在接收到其他线程信号时解除阻塞，并不继续阻塞，直到其复位。	40 ns
CountdownEvent	使线程在收到预订数量的信号时，解除阻塞。	40 ns
Barrier	实现线程执行屏障。	80 ns
Wait 和 Pulse	使线程阻塞，直到自定义条件被满足。	Pulse/120 ns

4.1 AutoResetEvent

AutoResetEvent 的原理类似于验票闸机，在闸机处调用 WaitOne() 方法，线程就会被阻塞。插入票的动作就类似于调用 Set() 方法打开闸机。任何能够访问这个 AutoResetEvent 的非阻塞线程都可以调用 Set() 方法来放行一个被阻塞的线程。

AutoResetEvent 是基于 EventWaitHandle 进行构造的，有两种方法可以创建 AutoResetEvent 对象。第一种即通过其构造方法 var auto = new AutoResetEvent (false); ，第二种则是通过 EventWaitHandle 传递事件类型，var auto = new EventWaitHandle (false, EventResetMode.AutoReset); 。这里如果传递的是 false 则会在创建后立即调用 Set() 方法。

class Program
{
 public static readonly EventWaitHandle WaitHandle = new AutoResetEvent(false);


 static void Main(string[] args)
 {
     var testClass = new AutoResetEventTest();

     new Thread(testClass.Waiter).Start();
     // 主线程等待 1 秒再发送信号唤醒
     Thread.Sleep(1000);

     WaitHandle.Set();
 }
}

public class AutoResetEventTest
{
 public void Waiter()
 {
     Console.WriteLine("线程开始等待...");
     // 如果传入了超时时间，超时则返回 false。
     Program.WaitHandle.WaitOne();
     Console.WriteLine("接受到了通知，进入闸机。");
 }
}

如果没有线程等待的时候调用 Set() 方法，则等待句柄会保持初始状态，直到有线程调用了 WaitOne() 方法。
为等待句柄调用 Reset() 方法可以关闭闸机，这个方法不会被阻塞。
可以调用 Dispose() 方法来销毁等待句柄，或者直接丢弃，等待 GC 进行回收。

如果主线程需要向工作线程连续发送 3 个信号并结束线程，则可以通过双向信号进行实现，其步骤大体如下。

启动工作线程。
主线程通过事件等待句柄 A 等待工作线程就绪。
工作线程通过 A 句柄通知主线程就绪，工作线程通过事件等待句柄 B 等待主线程通知。
主线程更改某个共享数据，通过句柄 B 通知工作线程进行处理。
工作线程收到信号唤醒之后，输出共享数据，并判断是否应该结束线程。
循环往复三次之后，工作线程收到的共享数据为 null，工作线程进行退出。

 static void Main(string[] args)
 {
     var testObj = new MultiAutoResetEventTest();

     new Thread(testObj.WorkThread).Start();

     MultiAutoResetEventTest.WaitHandle_MainThread.WaitOne();
     lock (MultiAutoResetEventTest.Locker) MultiAutoResetEventTest.Message = DateTime.Now.ToFileTimeUtc().ToString();
     MultiAutoResetEventTest.WaitHandle_WorkThread.Set();

     MultiAutoResetEventTest.WaitHandle_MainThread.WaitOne();
     lock (MultiAutoResetEventTest.Locker) MultiAutoResetEventTest.Message = DateTime.Now.ToFileTimeUtc().ToString();
     MultiAutoResetEventTest.WaitHandle_WorkThread.Set();

     MultiAutoResetEventTest.WaitHandle_MainThread.WaitOne();
     lock (MultiAutoResetEventTest.Locker) MultiAutoResetEventTest.Message = DateTime.Now.ToFileTimeUtc().ToString();
     MultiAutoResetEventTest.WaitHandle_WorkThread.Set();

     MultiAutoResetEventTest.WaitHandle_MainThread.WaitOne();
     lock (MultiAutoResetEventTest.Locker) MultiAutoResetEventTest.Message = null;
     MultiAutoResetEventTest.WaitHandle_WorkThread.Set();
 }
}

public class MultiAutoResetEventTest


  
  
   
    共2页: 
上一页
1
2
下一页


 
 
  
 
 
  

  
 
 
 
栏目列表
  
      
      
      
      
    
    
    

    
    
    


 




 





 



 






 




 
  
 
         
    最新更新
        

    
                      
              nodejs爬虫
     
Python正则表达式完全指南
     
爬取豆瓣Top250图书数据
     
shp 地图文件批量添加字段
     
爬虫小试牛刀（爬取学校通知公告）
     
【python基础】函数-初识函数
     
【python基础】函数-返回值
     
HTTP请求：requests模块基础使用必知必会
     
Python初学者友好丨详解参数传递类型
     
如何有效管理爬虫流量？
     



    
                  SQL SERVER中递归
     
2个场景实例讲解GaussDB(DWS)基表统计信息估
     
常用的 SQL Server 关键字及其含义
     
动手分析SQL Server中的事务中使用的锁
     
openGauss内核分析：SQL by pass & 经典执行
     
一招教你如何高效批量导入与更新数据
     
天天写SQL，这些神奇的特性你知道吗？
     
openGauss内核分析：执行计划生成
     
[IM002]Navicat ODBC驱动器管理器 未发现数据
     
初入Sql Server 之 存储过程的简单使用
     



              这是目前我见过最好的跨域解决方案！
     
减少回流与重绘
     
减少回流与重绘
     
如何使用KrpanoToolJS在浏览器切图
     
performance.now() 与 Date.now() 对比
     
一款纯 JS 实现的轻量化图片编辑器
     
关于开发 VS Code 插件遇到的 workbench.scm.
     
前端设计模式——观察者模式
     
前端设计模式——中介者模式
     
创建型-原型模式






 




相关教程





python基础教程
软件开发
PHP教程
sql教程
vb.net教程
sql语句大全
asp.net教程
dreamweaver教程
javascript教程
flash教程
vb教程
计算机二级vfp
access教程
html5教程
C#教程
web前端 
python入门教程 





关于我们--广告服务--免责声明--本站帮助-友情链接--版权声明--联系我们

  
  
黑ICP备07002182号

首页 > Python基础教程 >