多线程-2(线程同步

简介: 今天我们来了解下什么是线程同步?

带着问题去思考!大家好。

今天我们来了解下什么是线程同步?

首先我们先知道这些概念和一些类;

  • 执行基本的原子性
  • Mutex类
  • SemaphoreSlim类
  • AutoResetEvent类
  • ManualRestEventSlim类
  • CountDownEvent类
  • Barrier类
  • ReaderWriterLockSilm类
  • SpinWait类

我们都知道确保当一个线程使用某些资源的时候,同时其他线程无法使用该资源。这引入一个概念是共享资源。

多个线程同时使用共享对象会造成很多问题。同步线程使得对共享对象的操作能够以正确的顺序执行是非常重要的。

首先通过一个加减例子了解下lock处理

image.png

我们知道,最终结果应该是0;

因为第一个线程得到count为10增加为11,第二个线程得到的值是11并增加为12.第一个线程得到count为12,但是递减操作发生前,第二个线程得到的值也是12,。然后第一个线程将12递减11并保存count中,同时第二个线程进行了同样的操作,结果我们进行了两次递增操作但是只有一次递减操作。这是竞争条件(race condition)

1:请尽量避免使用共享对象

2:必须是共享的状态时候,使用原子操作。一个操作只占一个量子的时间,一次完成。这说明只有当前操作完成后,其他线程才能执行其他操作,避免死锁,和使用锁

3:使用不同方式来协调线程

  • 将等待的线程置于阻塞状态。当线程阻塞状态,只会占用少量CPU时间,意味将引入至少一次所谓的上下文切换(context switch上下文切换是操作系统的线程调度器).该调度器会保存等待的线程等待,并切换到另一个线程,依次恢复等待的线程的状态。这需要消耗很多资源,但是如果线程要被挂起很长时间的话,这是值得的---内核模式(kernel-mode)
  • 线程只需要等待一小段时间,不用将线程切换到阻塞状态。虽然线程等待时会浪费CPU时间,但节省了上下文切换耗费的CPU时间----用户模式(user-mode)
  • 先尝试使用用户模式等待,如果线程等待足够长时间。则会切换到阻塞状态节省CPU资源---混合模式(hybrid)

执行基本的原子操作

不用阻塞线程就可避免竞争条件

publicclass CounterLock : CounterBase     {         publicint Count { get; privateset; }         publicint _count;         publicoverridevoid Decrement()         {                          Interlocked.Decrement(ref _count);         }         publicoverridevoid Increment()         {             Interlocked.Increment(ref _count);         }             }

我们修改CounterLock,再来看看结果

image.png

我们可能会得到0,但是最终会得到一些不确定的非0.第一个例子是线程不安全的。第二个例子中,我们借助Interlocked类,无需锁定任何对象即可获取正确结果。Interlocked提供了Increment.Decrement和Add基于数学操作的原子方法,编写Counter类时无需使用锁、

Mutex类

conststring MutexName = "CSharpThreadingCookbook";         staticvoid Main(string[] args)         {             using (var m=new Mutex(false,MutexName))             {                 if(!m.WaitOne(TimeSpan.FromSeconds(5),false))                 {                     Console.WriteLine("Second instance is running!");                 }                 else                {                     Console.WriteLine("Running!");                     Console.ReadLine();                     m.ReleaseMutex();                 }             }         }

image.png

程序启动,定义一个指定名称的互斥量,设置initialOwner标志为false,这意味着如果互斥量已经被创建,则允许程序获取该互斥量。如果没有获得互斥量,程序则简单显示Running

在运行同样一个程序,则会在5秒种内尝试获得互斥量,如果此时在第一个程序中按下任意键,第二个程序则会开始执行。然而如果保持等待5秒,第二个程序无法获得该互斥量

image.png

主要用到不同的的程序中的线程

相关文章
|
16天前
|
存储 Java 数据库连接
java多线程之线程通信
java多线程之线程通信
|
27天前
|
存储 缓存 NoSQL
Redis单线程已经很快了6.0引入多线程
Redis单线程已经很快了6.0引入多线程
31 3
|
30天前
|
消息中间件 安全 Linux
线程同步与IPC:单进程多线程环境下的选择与权衡
线程同步与IPC:单进程多线程环境下的选择与权衡
58 0
|
1月前
|
Java 调度 C#
C#学习系列相关之多线程(一)----常用多线程方法总结
C#学习系列相关之多线程(一)----常用多线程方法总结
|
1月前
|
安全 编译器 C#
C#学习相关系列之多线程---lock线程锁的用法
C#学习相关系列之多线程---lock线程锁的用法
|
1月前
|
Java C#
C#学习系列相关之多线程(五)----线程池ThreadPool用法
C#学习系列相关之多线程(五)----线程池ThreadPool用法
|
1月前
|
存储 安全 Java
深入理解 Java 多线程、Lambda 表达式及线程安全最佳实践
线程使程序能够通过同时执行多个任务而更有效地运行。 线程可用于在不中断主程序的情况下在后台执行复杂的任务。 创建线程 有两种创建线程的方式。 扩展Thread类 可以通过扩展Thread类并覆盖其run()方法来创建线程:
109 1
深入理解 Java 多线程、Lambda 表达式及线程安全最佳实践
|
1月前
|
缓存 安全 Java
保障线程安全性:构建可靠的多线程应用
保障线程安全性:构建可靠的多线程应用
|
1月前
|
数据采集 存储 Java
「多线程大杀器」Python并发编程利器:ThreadPoolExecutor,让你一次性轻松开启多个线程,秒杀大量任务!
「多线程大杀器」Python并发编程利器:ThreadPoolExecutor,让你一次性轻松开启多个线程,秒杀大量任务!
|
1天前
|
安全 算法 Java
JavaSE&多线程&线程池
JavaSE&多线程&线程池
15 7