zoukankan      html  css  js  c++  java
  • 【转载】5天不再惧怕多线程——第三天 互斥体

    没想到我的前两篇文章还挺受欢迎的,谢谢大家,今天整理下Mutex的使用。

    一:Mutex

    首先看下MSDN对它的解释:

         不错,出现了一个亮点,可用于“进程间同步“,既然进程间都可以同步,那线程同步对它来说不是小菜一碟吗?好的,还是看下Mutex在

    线程中发挥的神奇功效。

    1: 线程间同步

        Metux中提供了WatiOne和ReleaseMutex来确保只有一个线程来访问共享资源,是不是跟Monitor很类似,下面我还是举个简单的例子,

    注意我并没有给Metux取名字。

    复制代码
     1 class Program
    2 {
    3 static void Main(string[] args)
    4 {
    5 for (int i = 0; i < 20; i++)
    6 {
    7 Thread t = new Thread(Run);
    8
    9 t.Start();
    10 }
    11
    12 Console.Read();
    13 }
    14
    15 static int count = 0;
    16
    17 static Mutex mutex = new Mutex();
    18
    19 static void Run()
    20 {
    21 Thread.Sleep(100);
    22
    23 mutex.WaitOne();
    24
    25 Console.WriteLine("当前数字:{0}", ++count);
    26
    27 mutex.ReleaseMutex();
    28 }
    29 }
    复制代码


    2:进程间同步

        这次我给Mutex取个名字叫cnblogs,把Console程序copy一份,然后看看真的能够实现进程同步吗?

    复制代码
     1  class Program
    2 {
    3 static void Main(string[] args)
    4 {
    5 Thread t = new Thread(Run);
    6
    7 t.Start();
    8
    9 Console.Read();
    10 }
    11
    12 static Mutex mutex = new Mutex(false, "cnblogs");
    13
    14 static void Run()
    15 {
    16 mutex.WaitOne();
    17
    18 Console.WriteLine("当前时间:{0}我是线程:{1},我已经进去临界区", DateTime.Now, Thread.CurrentThread.GetHashCode());
    19
    20 //10s
    21 Thread.Sleep(10000);
    22
    23 Console.WriteLine(" 当前时间:{0}我是线程:{1},我准备退出临界区", DateTime.Now, Thread.CurrentThread.GetHashCode());
    24
    25 mutex.ReleaseMutex();
    26 }
    27 }
    复制代码

    3:  小结

    ①:  当给Mutex取名的时候能够实现进程同步,不取名实现线程同步,详细细节参考MSDN:

    ②: Mutex封装了win32的同步机制,而Monitor是由framework封装,所以在线程同步角度来说,Monitor更加短小精悍,优于Mutex,要是实现进程

           同步,Monitor也干不了,所以Mutex是首选。

    二:Interlocked

    同样先向MSDN讨个说法,看看如何解释。

    ”原子操作”是个亮点,我们知道“原子”是不可再分的,深一点的意思就是说站在程序员的角度来看是不需要手工干预的,也就是所谓的“无锁编程”。

    实际应用中有时候我们可能只是对共享变量进行一些简单的操作,比如说“自增,自减,求和,赋值,比较"。

    1:Increment

        看看是不是达到了不可再分的自增效果,蛮有意思。

    复制代码
     class Program
    {
    static void Main(string[] args)
    {
    for (int i = 0; i < 20; i++)
    {
    Thread t = new Thread(Run);

    t.Start();
    }

    Console.Read();
    }

    static int count = 0;

    static Mutex mutex = new Mutex();

    static void Run()
    {
    Thread.Sleep(100);

    Console.WriteLine("当前数字:{0}", Interlocked.Increment(ref count));
    }
    }
    复制代码

    2:Decrement

        这个就不用举例子了。

    3:Add

        发现MSDN解释的还是蛮详细的。

    复制代码
    1      static void Main(string[] args)
    2 {
    3 int i = 10;
    4
    5 Interlocked.Add(ref i, 20);
    6
    7 Console.WriteLine(i); //i=30
    8 }
    复制代码


    4:Exchange

         这个就是所谓的原子性赋值操作

    复制代码
    1  static void Main(string[] args)
    2 {
    3 int i = 10;
    4
    5 Interlocked.Exchange(ref i, 30);
    6
    7 Console.WriteLine(i); //i=30
    8 }
    复制代码

    5:CompareExchange

        所谓的比较操作,还是看看经典的MSDN的说法

    如果相等,返回第二个参数值:

    复制代码
      static void Main(string[] args)
    {
    int i = 10;

    Interlocked.CompareExchange(ref i, 30, 10);

    Console.WriteLine(i); //i=30
    }
    复制代码

    如果不相等,则返回原始值:

    复制代码
    1  static void Main(string[] args)
    2 {
    3 int i = 10;
    4
    5 Interlocked.CompareExchange(ref i, 30, 100);
    6
    7 Console.WriteLine(i); //i=10
    8 }

    转载地址:http://www.cnblogs.com/huangxincheng/archive/2012/03/16/2402320.html

  • 相关阅读:
    Kali Linux下安装配置ProFTPD实例
    mysql 如何用root 登录
    串口总是报'Error opening serial port'
    用SPCOMM 在 Delphi中实现串口通讯 转
    delphi中使用spcomm来实现串口通讯(转载)
    SPCOMM的一些用法注意
    MySQL 字符串 转 int/double CAST与CONVERT 函数的用法
    彻底删除mysql服务
    mysql 非安装版的一个自动安装脚本及工具(更新版)
    bat操作数据库mysql
  • 原文地址:https://www.cnblogs.com/yy981420974/p/6846094.html
Copyright © 2011-2022 走看看