【转】细说.NET中的多线程 (四 使用锁进行同步)

通过锁来实现同步

排它锁主要用来保证,在一段时间内,只有一个线程可以访问某一段代码。两种主要类型的排它锁是lock和Mutex。Lock和Mutex相比构造起来更方便,运行的也更快。但是Mutex可以在同一个机器上的不同进程使用

Monitor.Enter和Monitor.Exit

C#中的lock关键字,实际上是Monitor.Enter,Monitor.Exist的一个简写。在.NET 1.0,2.0,3.0 版本的c#中,lock会被编译成如下代码:

1
2
3
4
5
6
7
Monitor.Enter(_locker);
try
{
    if (_val2 != 0) Console.WriteLine(_val1 / _val2);
    _val2 = 0;
}
finally { Monitor.Exit(_locker); }

如果你没有调用Monitor.Enter而直接调用Monitor.Exit会引发异常。

LockTaken版本:

想象一下上面这段代码,如果再Monitor.Enter之后,try之前,线程出现了异常(比如被终止),在这种情况下,finally中的Exit方法就永远不会被执行,也就导致了这个锁不会被释放。为了避免这种情况,CLR 4.0的设计者重载了Monitor.Enter方法:

1
public static void Enter (object obj, ref bool lockTaken);

 

如果当前线程由于某些异常导致锁没有被获取到,lockTake值会为false,因此在CLR 4.0中,lock会被解释成如下代码:

1
2
3
4
5
6
7
8
9
10
bool lockTaken = false;
try
{
 
    Monitor.Enter(_locker, ref lockTaken);
 
    // Do your stuff...
}
 
finally if (lockTaken) Monitor.Exit(_locker); }

TryEnter

Monitor也提供了了一个TryEnter方法,允许你设置一个超时时间,避免当前线程长时间获取不到锁而一直等待。

选择正确的同步对象

你需要选择一个对所有线程都可见的对象进行lock(obj)来确保程序能够按照你的意图执行。如果你不了解C#语言中的某些特性,lock可能不会按照你 期望来执行。

  1. 由于字符串的驻留机制,lock("string")不是一个好的选择
  2. Lock一个值类型不是一个好的选择
  3. Lock(typeof(..))不是一个好的选择,因为System.Type的特性

什么时候使用lock

一个基本的规则,你需要对任意的写操作,或者可修改的字段进行lock。即使是一个赋值操作,或者累加操作,你也不能假设他是线程安全的。

例如下面代码不是线程安全的:

1
2
3
4
5
6
class ThreadUnsafe
{
    static int _x;
    static void Increment() { _x++; }
    static void Assign() { _x = 123; }
}

 

你需要这样写:

1
2
3
4
5
6
7
8
class ThreadSafe
{
    static readonly object _locker = new object();
    static int _x;
 
    static void Increment() { lock (_locker) _x++; }
    static void Assign() { lock (_locker) _x = 123; }
}

如果你看过一些BCL类库里面的实现,你可以能会发现,某些情况下会使用InterLocked类,而不是lock,我们会在后面介绍。

关于嵌套锁或者reentrant

你在阅读一些文档的时候,有的文档可能会说lock或者Monitor.Enter是reentrant(可重入的),那么我们如何理解reentrant呢?

想象下以下代码:

1
2
3
4
5
6
lock (locker)
    lock (locker)
        lock (locker)
        {
            // Do something...
        }

 

或者是:

1
2
3
Monitor.Enter(locker); Monitor.Enter(locker); Monitor.Enter(locker);
// Do something...
Monitor.Exit(locker); Monitor.Exit(locker); Monitor.Exit(locker);

这种情况下,只有在最后一个exit执行后,或者执行了相应次数的Exit后,locker才是可获取的状态。

Mutex

Mutex像c#中的lock一样,但是在不同的进程中仍然可以使用。换句话说,Mutex是一个计算机级别的锁。因此获取这样一个锁要比Monitor慢很多。

示例代码:

 

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
using System;
using System.Threading.Tasks;
using System.Threading;
 
namespace MultiThreadTest
{
    class OneAtATimePlease
    {
        static void Main()
        {
            // Naming a Mutex makes it available computer-wide. Use a name that's
            // unique to your company and application (e.g., include your URL).
 
            using (var mutex = new Mutex(false"oreilly.com OneAtATimeDemo"))
            {
                // Wait a few seconds if contended, in case another instance
                // of the program is still in the process of shutting down.
 
                if (!mutex.WaitOne(TimeSpan.FromSeconds(3), false))
                {
                    Console.WriteLine("Another app instance is running. Bye!");
                    return;
                }
                RunProgram();
            }
        }
 
        static void RunProgram()
        {
            Console.WriteLine("Running. Press Enter to exit");
            Console.ReadLine();
        }
    }
}

Semaphore

Monitor和Mutex都是排他锁,Semaphore我们常用的另外一种非排他的锁。

我们用它来实现这样一个例子:一个酒吧,最多能容纳3人,如果客满则需要等待,有客人离开,等待的人随时可以进来。

示例代码:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
using System;
using System.Threading;
 
class TheClub      // No door lists!
{
    static Semaphore _sem = new Semaphore(3, 3);    // Capacity of 3
 
    static void Main()
    {
        for (int i = 1; i <= 5; i++) new Thread(Enter).Start(i);
 
        Console.ReadLine();
    }
 
    static void Enter(object id)
    {
        Console.WriteLine(id + " wants to enter");
        _sem.WaitOne();
        Console.WriteLine(id + " is in!");           // Only three threads
        Thread.Sleep(1000 * (int)id);               // can be here at
        Console.WriteLine(id + " is leaving");       // a time.
        _sem.Release();
    }
}

 

使用Semaphore需要调用者来控制访问资源,调用WaitOne来获取资源,通过Release来释放资源。开发者有责任确保资源能够正确释放。

Semaphore在限制同步访问的时候非常有用,它不会像Monitor或者Mutex那样当一个线程访问某些资源时,其它所有线程都需要等,而是设置一个缓冲区,允许最多多少个线程同时进行访问。

Semaphore也可以像Mutex一样,跨进程进行同步。

 

本节主要总结了使用锁进行同步,下一节将总结使用信号量进行同步。     

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/436692.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

发现很多人的基础都不好

加了一些C#的qq群&#xff0c;有一次提了一个很简单的问题&#xff0c;关于abstract class的&#xff08;具体问题忘记了&#xff09;&#xff0c;很多人都搞不清楚。还有一些所谓在做项目的&#xff0c;只是拖些控件&#xff0c;做个界面&#xff08;界面还挺漂亮的&#xff0…

oracle ora-22288,向oracle的blob字段导入文件

在数据库主机上创建测试目录及文件$mkdir /test$cd /test$echo "Test Subject" >> subject.html$echo "test ok !" >> mail.html定义文件路径(都是数据库主机上的)&#xff0c;并授权$sqlplus user/passwdinstanceSQL>create or replace di…

【转】细说.NET中的多线程 (五 使用信号量进行同步)

上一节主要介绍了使用锁进行同步&#xff0c;本节主要介绍使用信号量进行同步 使用EventWaitHandle信号量进行同步 EventWaitHandle主要用于实现信号灯机制。信号灯主要用于通知等待的线程。主要有两种实现&#xff1a;AutoResetEvent和ManualResetEvent。 AutoResetEvent …

做自己喜欢的人

1&#xff09;首先做一个快乐的人 什么是成功&#xff1f; 有钱是不是成功&#xff1f;地位是不是成功&#xff1f; 成功就是实现自己有意义的既定的目标 为自己设定阶段性的目标&#xff0c;如果达成这些阶段性的目标就是成功 1)工作2)学习3&#xff09;家庭生活 三个方面的目…

oracle只匹配中文,Oracle 实现 一个关键字 匹配多个 字段

有这么一个需求&#xff0c;满足只有一个输入框的条件下&#xff0c;支持不同数据列的搜索结果。说白了&#xff0c;就是这个 输入框 既可以用来 搜索姓名&#xff0c;也可以搜索 年龄&#xff0c;地址等。分析&#xff1a;一般情况下&#xff0c;我们的一个输入框对应 数据库…

【转】细说.NET中的多线程 (六 使用MemoryBarrier,Volatile进行同步)

上一节介绍了使用信号量进行同步&#xff0c;本节主要介绍一些非阻塞同步的方法。本节主要介绍MemoryBarrier&#xff0c;volatile,Interlocked。 MemoryBarriers 本文简单的介绍一下这两个概念&#xff0c;假设下面的代码&#xff1a; 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 …

主题:的中间层框架 第一节

主题:<插件式>的中间层框架 时间:2004-12-31 15:00 主讲:D10.天地弦 2004-12-31 14:56:15 /:>D10.天地弦(185511468) 开始吧&#xff0c;我们 2004-12-31 14:57:22 /:>D10.天地弦(185511468) 请大家先看图 http://www.jqk.net.cn/dkFrameworkWeb/dkFramework_fi…

qt5.11 linux oracle,Qt5.11.1 + VS2017环境搭建(Qt5.11在windows上的安装)

安装视频&#xff1a;《Qt5.11在windows‘上的编译安装》安装VisualStudio2017VS2017安装包 提取码&#xff1a;7db11&#xff0c;安装vs2017请确保勾选了“通用Windows平台开发”组件&#xff0c;否则VS2017将无法用来进行开发右侧的安装详细信息部分也尽量与上图一致。安装完…

【转】Git Shell 基本命令(官网脱水版)

用户信息 当安装完 Git 应该做的第一件事就是设置你的用户名称与邮件地址。 这样做很重要&#xff0c;因为每一个 Git 的提交都会使用这些信息&#xff0c;并且它会写入到你的每一次提交中&#xff0c;不可更改&#xff1a; $ git config –global user.name “John Doe” $ …

oracle 采购 日历,Oracle日历程序

运行之前要先设置好环境,即定义好年份:DEFINE YEAR&YEAR要查看其它年份,就再执行:def year&year1然后再执行下面的脚本:select casewhen (new_yweek min(new_yweek)over(partition by mon order by new_yweek)) thenmon_nameelsenullend as month,new_yweek as yweek,…

回到家了

经过漫长的旅途&#xff0c;总算从海口回到家里了&#xff0c;今天开通了网络&#xff0c;速度比学校好多了。突然发现文本编辑器变漂亮了&#xff0c;呵呵&#xff0c;DuDu真是努力。家里果然冷多了&#xff0c;想想前几天在海口都可以穿短袖了&#xff0c;现在又穿上了厚厚的…

【转】Dynamics 365中的事件框架与事件执行管道(Event execution pipeline)

本文介绍了Microsoft Dynamics 365&#xff08;以下简称D365&#xff09;中的两个概念&#xff0c;事件框架&#xff08;Event Framework&#xff09;与事件执行管道&#xff08;Event execution pipeline&#xff09;。 本文适用于&#xff1a;Applies To: Dynamics 365 (onl…

oracle临时表空间组,证明临时表空间组在并发session时的作用

本帖最后由 zcs0237 于 2013-7-16 20:26 编辑a.感谢对本帖补充、建议、错误更正b.为节省篇幅&#xff0c;部分输出结果做了精简c.可按本文先后顺序复制文中代码进程调试d.测试环境:Ora10.2.0.1.0(Ora11.2.0.1.0暂时还没测)****************************证明不同session会调用临…

家乡的楼房正在往高层发展

几年前家乡的楼房都是一马平川&#xff0c;偶尔有些鹤立鸡群的楼房就能一览众山小&#xff0c;到了上海看到随处可见的摩天大厦&#xff0c;感叹家乡何时才能拥有如此的繁华。 今年回到家乡发现有多座大楼正拨地而起&#xff0c;虽然有特色的没有几座&#xff0c;但高大耸立的楼…

【转】ABP源码分析二十:ApplicationService

IApplicationService : 空接口&#xff0c;起标识作用。所有实现了IApplicationService 的类都会被自动注入到容器中。同时所有IApplicationService对象都会被注入一些拦截器&#xff08;例如&#xff1a;auditing, UnitOfWork等&#xff09;以实现AOP AbpServiceBase&#xf…

oracle 600 session,记一次ORA-600[4042]故障的处理

【IT168 技术文档】一套运行在Linux下的Oracle 9.2.0.4的库&#xff0c;出现了大量的ORA-600[4042]错误。ORA-00600: internal error code, arguments: [4042], [31760], [], [], [], [], [], []ORA-00600: internal error code, arguments: [4042], [31760], [], [], [], [], …

权限系统思路

1、角色只与模块&#xff08;功能&#xff09;对应 2、具备“管理选项”的角色可被授予其他角色&#xff08;这是从Oracle得到的启发&#xff09;转载于:https://www.cnblogs.com/xiaotaoliang/archive/2005/02/26/109463.html

【转】ADFS 概念与基本开发介绍

&#xff08;如您转载本文&#xff0c;必须标明本文作者及出处。如有任何疑问请与我联系 menap7.com&#xff09; ADFS 相关开发技术的中文资料相对匮乏&#xff0c;之前在弄这个东西的时候搞的比较辛苦&#xff0c;因此总结此文档&#xff0c;以解后人之忧。 本文会首先介绍…

oracle更新数据没反应,ORACLE更新数据时如果有就更新没有就插入

SQL写法&#xff1a;beginupdate table_name set salary 10000 where emp_id 5;if sql%notfound theninsert into table_name (id,name,salary)values("","","") ;end if;end;SQL%NOTFOUND 是一个布尔值。与最近的sql语句(update,insert,delet…

【转】使用FiddlerCore来测试WebAPI

大家在调试Web相关的API时&#xff0c;经常会用Fiddler来查看相关的请求&#xff0c;以及返回结果。当然你也可以尝试修改或者重复发送你的请求信息。本文主要介绍如何使用代码来实现fiddler的功能。 Fiddler Core API Fiddler Core几乎实现了你能用fiddler做的所有功能。直接…