首页 > 编程语言 >C#线程:非排他锁

C#线程:非排他锁

时间:2022-08-31 15:13:39浏览次数:64  
标签:Thread C# 非排 读锁 static new 线程 void

非排他锁目的是限制并发性。

信号量

信号量(semaphore)就像俱乐部一样:它有特定的容量,还有门卫保护。在满员之后,就不允许其他人进入了,人们只能在外面排队。只有当有人离开时,才准许另外一个人进入。信号量的构造器需要至少两个参数:即俱乐部当前的空闲容量以及俱乐部的总容量。
容量为1的信号量与Mutex和lock类似,但是信号量没有持有者这个概念,它与线程无关。任何线程都可以调用Semaphore的Release方法。Mutex和lock则不然,只有持有锁的线程才能够释放锁。

信号量可用于限制并发性,防止太多线程同时执行特定的代码。
在下面的例子中,5个线程试图进入俱乐部,但最多只允许3个线程同时进入:

static SemaphoreSlim _sem = new SemaphoreSlim(3);
static void Enter(object id)
{
    Console.WriteLine(id + " wants to enter");
    _sem.Wait();
    Console.WriteLine(id + " is in!");
    Thread.Sleep(1000 * (int)id);
    Console.WriteLine(id + " is leaving");
    _sem.Release();
}
static void Main(string[] args)
{
    for (int i = 1; i <= 5; i++)
        new Thread(Enter).Start(i);
    Console.ReadKey();
}

// 运行结果
1 wants to enter
4 wants to enter
2 wants to enter
3 wants to enter
5 wants to enter
4 is in!
2 is in!
1 is in!
1 is leaving
3 is in!
2 is leaving
5 is in!
3 is leaving
4 is leaving
5 is leaving

异步信号量与锁

在await语句周围使用锁是非法的:

lock(_locker)
{
    await Task.Delay(1000);
    ...
}

这是因为上述语句没有任何意义。锁是由线程持有的,而await返回时线程往往会发生变化。锁还会阻塞,而长时间的阻塞正是异步函数希望避免的情形。

但有时,我们仍期望异步函数按顺序执行,或至少限制其并发性,让不多于n个操作同时执行。例如,Web浏览器会并行执行异步的下载操作。但是它可能期望对此引入一些限制,例如同时执行的下载操作不得超过10个。此时可以使用SemaphoreSlim来实现该功能:

SemaphoreSlim _semaphore = new SemaphoreSlim(10);
async Task<byte[]> DownloadWithSemaphoreAsync(string uri)
{
    await _semaphore.WaitAsync();
    try
    {
        return await new WebClient().DownloadDataTaskAsync(uri);
    }
    finally
    {
        _semaphore.Release();
    }
}

将信号量的initialCount设置为1会将最大并行数目设置为1,即它会变为一个异步锁。

读写锁

通常,一个类型实例的并发读操作是线程安全的,其并发更新操作则不然。虽然可以简单地使用一个排他锁来保护对实例的任何形式的访问,但是如果其读操作很多但更新操作很少,则使用单一的锁限制并发性就不太合理了。这种情况常出现在业务应用服务器上,它会将常用的数据缓存在静态字段中进行快速检索。ReaderWriterLockSlim是专门为这种情形而设计的,它可以最大限度地保证锁的可用性。
ReaderWriterLockSlimReaderWriterLock都拥有两种基本的锁,即读锁和写锁:

  • 写锁是全局排他锁。
  • 读锁可以兼容其他的读锁。

因此,持有写锁的线程将阻塞其他任何试图获取读锁或写锁的线程(反之亦然)。但是如果没有任何线程持有写锁的话,其他任意数量的线程都可以并发获得读锁。ReaderWriterLockSlim类定义了以下的方法来获得和释放读写锁:

public void EnterReadLock();
public void ExitReadLock();
public void EnterWriteLock();
public void ExitWriteLock();

以下示例演示了ReaderWriterLockSlim的用法。三个线程将持续枚举列表中的元素,另有两个线程则会每隔100毫秒生成一个随机数,并试图将该数字加入列表中。其中,读锁保护列表的读操作,写锁保护列表的写操作:

static ReaderWriterLockSlim _rw = new ReaderWriterLockSlim();
static List<int> _items = new List<int>();
static Random _rand = new Random();

static void Main(string[] args)
{
    new Thread(Read).Start();
    new Thread(Read).Start();
    new Thread(Read).Start();

    new Thread(Write).Start("A");
    new Thread(Write).Start("B");

    Console.ReadKey();
}

static void Read()
{
    while (true)
    {
        _rw.EnterReadLock();
        foreach (int i in _items)
            Thread.Sleep(10);
        _rw.ExitReadLock();
    }
}

static void Write(object threadID)
{
    while (true)
    {
        int newNumber = GetRandNum(100);
        _rw.EnterWriteLock();
        _items.Add(newNumber);
        _rw.ExitWriteLock();
        Console.WriteLine("线程 " + threadID + " 添加: " + newNumber);
        Thread.Sleep(100);
    }
}

static int GetRandNum(int max)
{
    lock (_rand)
        return _rand.Next(max);
}

ReaderWriterLockSlim相比简单的锁能提供更多的并发Read操作。如:_rw.CurrentReadCount就能得到当前读锁的并发个数,上例是3个。除了这个,还提供了其他监视锁状态的属性。

可升级锁

有时最好能在一个原子操作中将读锁转换为写锁。例如,我们希望当列表不包含特定元素时才将这个元素添加到列表中。理想情况下,我们希望尽可能缩短持有写锁(排他锁)的时间,假设可以采取如下的操作步骤:

  1. 获取一个读锁。
  2. 判断该元素是否已经位于列表中,如果确已存在,则释放读锁并返回。
  3. 释放读锁。
  4. 获得写锁。
  5. 添加该元素。

上述操作的问题在于,另一个线程可能会在第3和第4步之间插入并修改列表(例如,添加同一个元素)。而ReaderWriterLockSlim可以通过第三种锁来解决这个问题,该锁称为可升级锁。可升级锁就像读锁一样,但是它可以在随后通过一个原子操作升级为写锁。以下是其使用方式:

  1. 调用EnterUpgradeableReadLock
  2. 执行读操作(例如,判断该元素是否已经存在于列表中)。
  3. 调用EnterWriteLock(该操作将可升级锁转化为写锁)。
  4. 执行写操作(例如,将该元素添加到列表中)。
  5. 调用ExitWriteLock(将写锁转换回可升级锁)。
  6. 执行其他读操作。
  7. 调用ExitUpgradeableReadLock

从调用者的角度来看,这种操作和嵌套锁或者递归锁很相似。但是,从功能上,第3步中ReaderWriterLockSlim释放读锁并获得写锁的操作是原子的。

可升级锁和读锁还有一个重要区别:虽然可升级锁可以和任意数目的读锁并存,但是一次只能获取一个可升级锁。
我们对前一个例子的Write方法稍做修改来演示可升级锁的用法。这次仅在列表中不存在相应数字时才会将数字添加到列表中:

static void Write (object threadID)
{
    while (true)
    {
        int newNumber = GetRandNum (100);
        _rw.EnterUpgradeableReadLock();
        if (!_items.Contains (newNumber))
        {
            _rw.EnterWriteLock();
            _items.Add (newNumber);
            _rw.ExitWriteLock();
            Console.WriteLine ("Thread " + threadID + " added " + newNumber);
        }
        _rw.ExitUpgradeableReadLock();
        Thread.Sleep (100);
    }
}

标签:Thread,C#,非排,读锁,static,new,线程,void
From: https://www.cnblogs.com/nullcodeworld/p/16643150.html

相关文章

  • js 实现watch监听数据变化的代码
    /***@desc属性改变监听,属性被set时出发watch的方法,类似vue的watch*@constructor*@param{object}opts-构造参数.@default{data:{},watch:{}};*@argument......
  • UIPATH Orchestrator配置
    Orchestrator简介UiPathOrchestrator是一个网页应用程序,使您能够在执行重复的业务流程时编排UiPath机器人。Orchestrator使您可以管理环境中资源的创建、监控和部署......
  • c#中的delegate
    delegate的用法类似于c++中的函数指针,目的都是将操作方法作为变量进行传递,用法如下://定义delegate类型delegateboolTestDele(stringkey,Objectvalue);//用定义好......
  • Centos7.9离线安装ORACLE19C
    一、基础环境配置1、关闭系统防火墙systemctlstopfirewalldsystemctldisablefirewalld2、关闭selinuxvim/etc/selinux/configSELINUX=disabled3、准备安装......
  • Orcle 命令面板的操作
    SQL>showuser;显示当前登录用户SQL>clearscreen;清空屏幕SQL>hostcls;清空屏幕SQL>spool(保存的路径假设为A)将以下执行的sql语句和执行结果......
  • Cesiun 之 CallbackProperty
    CallbackPropertyCesium号称是集显示时空数据于一体的三维引擎。空间数据的展示我们已经见到,对于时间上的数据,我觉得CallbackProperty是最大功臣。因为使用CallbackProper......
  • erlang的一次docker部署尝试
    背景最近需要在arm64和x86平台上,多个系统版本上部署,被环境问题折磨的焦头烂额。因为erlang本身是基于C语言的,基于不同的gcc环境编译的包不能很好的运行。docker用于解决开......
  • Linux centos7 删除多余内核
    Linux下可能会存在有多个内核的情况,通过某一内核启动会出现无法登录的情况,这时我们就要选择可以正常登录的内核,成功进入系统后,将多余的内核删除。检查系统中的内核 ......
  • AllegroPCB封装制作规则
    AllegroPCB封装制作规则整理者:ZHOU邮箱:[email protected]制作元件流程新建元件封装放置焊盘  <Ecth-TOP>放置安装外框元件本体   <PackageGeometry-Assemb......
  • Android logcat命令详解
    一、logcat命令介绍1.androidlog系统 2.logcat介绍logcat是android中的一个命令行工具,可以用于得到程序的log信息log类是一个日志类,可以在代码中使用logcat打印......