.net中线程同步的典型场景和问题剖析

 更新时间:2021年9月22日 10:18  点击:1290
在使用多线程进行编程时,有一些经典的线程同步问题,对于这些问题,.net提供了多种不同的类来解决。除了要考虑场景本身,一个重要的问题是,这些线程是否在同一个应用程序域中运行。如果线程都在同一应用程序域中运行,则可以使用一些所谓“轻量”级的同步类,否则要使用另一些类,而这些类都是对操作系统所提供的同步原语的包装,相对来说更消耗资源。我在这儿介绍一些典型的应用场景和相关的问题。 

多线程争用独占资源
常常有一些资源线程独占的,如果有多个线程同时需要访问这要的资源,就形成了一个争用问题。这类资源有“文件”,“打印机”,“串口”,以及所有非线程安全的类对象(绝大部分类库中的类都是)。典型的代码:
复制代码 代码如下:

var objLock = new Object();
var thread1 = new Thread(() =>
{
lock (objLock)
{
AccessResource();
}
});
var thread2 = new Thread(() =>
{
lock (objLock)
{
AccessResource();
}
});

上面代码中,lock关键字实际上Monitor类的一个语法糖。任意一个对象(非值类型)上都有一个锁区域,Monitor.Enter方法会尝试锁定该区域,如果锁定成功,线程就拥有该对象,反子,线程将被挂起。对于objLock对象,有以下点需要注意:
不要锁定this
不要锁定Type
不要锁定字符串
不要锁定值类型的对象
对于相同的类,通常都会有很多不同的实例,这样的话,有可能会锁定到多个不同的对象上,从而使锁失效。不要锁定Type的原因有两点,一是生成Type类对象相对比较慢比较占资源,二是Type类型通常是公共的,这样有可能会在程序的多个不同地方会锁定,这实际上是个工程问题,主要是为了防止引入BUG。不要锁定string类,是因数,所有字面值相同的字符串,实际上是共享同一个对象的,所以和Type一样,也可能会无意间被别的代码锁定,这样的Bug将难以排除。不要锁定值类型,因为值类型本身是不可锁定的,为了可以锁定,编译器值将它装箱,而每次装箱实际上都会生成一个不同的对象实例,这样锁定也就没有任何效果了。
上面的代码有效的原因是所有线程都在同一个应用程序中,也就是不涉及进程间的资源争用。如果是多进程间的资源争用,可以使用Mutex类。Mutex类有两种不同用法,匿名互斥体和命名互斥体,命名的互斥体是在整个操作系统范围内共用的,所以可以用于进程间同步。
复制代码 代码如下:

var mutex = new Mutex(false, "name");
var thread1 = new Thread(() =>
{
try
{
mutex.WaitOne();
AccessResource();
}
finally
{
mutex.ReleaseMutex();
}
});
var thread2 = new Thread(() =>
{
try
{
mutex.WaitOne();
AccessResource();
}
finally
{
mutex.ReleaseMutex();
}
});

需要注意的是,在线程结束时,必须释放互斥体。一对一的生产者/消费者模型在这种模型中,有一个生产者线程在产生需要处理的数据,同时有一个消费者线程在处理数据,通常来说,数据存放在一个缓存中。在种情况下,生产者每产生一个数据,就将它放入缓存中,并设置信号量(WaitHandle),以通知消费者线程去处理。消费者不断的处理数据,如果发现所有数据都已经处理完毕,则进入阻塞状态,以等待生产者线程产生数据。信号量有两种,一种是AutoResetEvent,另一种是ManualResetEvent。前者的特点是每次设置一个信号后,将唤醒一个阻塞的线程,然后马上将信号量未设置状态。而后者的状态,则完全由程序控制,可能一次唤醒多个线程,也可能未唤醒作何一个线程。这种模型的例子代码。
复制代码 代码如下:

using System;
using System.Collections.Generic;
using System.Threading;
namespace ThreadCancle
{
public class ProducerConsumer2
{
public static void Main()
{
var autoResetEvent = new AutoResetEvent(false);
var queue = new Queue<int>();
var producterThread = new Thread(() =>
{
var rand = new Random();
while (true)
{
var value = rand.Next(100);
lock (queue)
{
queue.Enqueue(value);
}
Thread.Sleep(rand.Next(400, 1200));
Console.WriteLine("产生了数据{0}。", value);
autoResetEvent.Set();
}
});
var consumerThread = new Thread(() =>
{
while (true)
{
autoResetEvent.WaitOne();
int value = 0;
bool hasValue = true;
while (hasValue)
{
lock (queue)
{
hasValue = (queue.Count > 0);
if (hasValue)
{
value = queue.Dequeue();
}
}
Thread.Sleep(800);
Console.WriteLine("处理了数据{0}。", value);
}
}
});
producterThread.Start();
consumerThread.Start();
Console.ReadLine();
}
}
}

在上面的例子中,生产者间隔0.4-1.2秒产生一个需要处理的数据,而消费者的处理能力是每0.8秒处理一个数据。生产者不断的产生数据,并将它放入queue中,然后唤醒消费者线程。消费者线程将queue中所有的数据处理完成后进入阻塞状态。需要注意的是,消费者线程和生产者线程会同时对queue对象进行访问,所有每次访问它们的时候必须锁定。执行锁定的时候必须遵循最少占用时间原则,一旦使用完毕应当立即释放锁定。
[!--infotagslink--]

相关文章

  • C# WinForm多线程解决界面卡死问题的完美解决方案,使用BeginInvoke

    问题描述:当我们的界面需要在程序运行中不断更新数据时,当一个textbox的数据需要变化时,为了让程序执行中不出现界面卡死的现像,最好的方法就是多线程来解决一个主线程来创建界...2020-06-24
  • C#停止线程的方法

    这篇文章主要介绍了C#停止线程的方法,实例分析了C#正确停止线程的实现技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
  • C#开启线程的四种方式示例详解

    今天小编就为大家分享一篇关于C#开启线程的四种方式示例详解,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧...2020-06-25
  • C# 线程相关知识总结

    这篇文章主要介绍了C# 线程相关知识,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下...2020-11-03
  • c# 多线程处理多个数据的方法

    这篇文章主要介绍了c# 多线程处理多个数据的方法,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下...2021-03-31
  • C#实现跨线程操作控件方法

    这篇文章主要介绍了C#实现跨线程操作控件方法,主要采用异步访问方式实现,需要的朋友可以参考下...2020-06-25
  • C#基于委托实现多线程之间操作的方法

    这篇文章主要介绍了C#基于委托实现多线程之间操作的方法,实例分析了C#的委托机制与多线程交互操作的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
  • C#多线程中的异常处理操作示例

    这篇文章主要介绍了C#多线程中的异常处理操作,涉及C#多线程及异常的捕获、处理等相关操作技巧,需要的朋友可以参考下...2020-06-25
  • 浅析c# 线程同步

    这篇文章主要介绍了c# 线程同步的相关资料,帮助大家更好的理解和学习c#,感兴趣的朋友可以了解下...2020-08-29
  • MYSQL主从不同步延迟原理分析及解决方案

    1. MySQL数据库主从同步延迟原理。要说延时原理,得从mysql的数据库主从复制原理说起,mysql的主从复制都是单线程的操作,主库对所有DDL和DML产生binlog,binlog是顺序写,所以效率很高,slave的Slave_IO_Running线程到主库取日...2013-10-04
  • 深入分析C#中的异步和多线程

    这篇文章主要介绍了C#中异步和多线程的相关资料,帮助大家更好的理解和学习c#,感兴趣的朋友可以了解下...2021-01-16
  • C#多线程与异步的区别详解

    多线程和异步操作两者都可以达到避免调用线程阻塞的目的,从而提高软件的可响应性。甚至有些时候我们就认为多线程和异步操作是等同的概念。但是,多线程和异步操作还是有一些区别的。而这些区别造成了使用多线程和异步操作的时机的区别...2020-06-25
  • 解决线程并发redisson使用遇到的坑

    这篇文章主要介绍了解决线程并发redisson使用遇到的坑,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-06-18
  • C#多线程之Thread类详解

    这篇文章主要为大家详细介绍了C#多线程之Thread类,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2020-06-25
  • java中多线程与线程池的基本使用方法

    在Java中,我们可以利用多线程来最大化地压榨CPU多核计算的能力,下面这篇文章主要给大家介绍了关于java中多线程与线程池基本使用的相关资料,需要的朋友可以参考下...2021-09-13
  • C#向线程中传递多个参数的解决方法(两种)

    这篇文章主要介绍了C#向线程中传递多个参数的解决方法(两种)的相关资料,非常不错,具有参考借鉴价值,需要的朋友可以参考下...2020-06-25
  • C#中的多线程多参数传递详解

    第一种解决方案的原理是:将线程执行的方法和参数都封装到一个类里面。通过实例化该类,方法就可以调用属性来实现间接的类型安全地传递多个参数...2020-06-25
  • C#实现终止正在执行的线程

    这篇文章主要介绍了C#实现终止正在执行的线程的方法,针对临界资源等容易出现错误的地方进行了分析,并提出了改进方案与实例,需要的朋友可以参考下...2020-06-25
  • C#开启线程的四种示例

    这篇文章主要介绍了C#开启线程的四种方法,帮助大家更好的理解和使用c#,感兴趣的朋友可以了解下...2020-10-12
  • java多线程中执行多个程序的实例分析

    在本篇文章里小编给大家整理的是一篇关于java多线程中执行多个程序的实例分析内容,有需要的朋友们可以学习参考下。...2021-02-07