您现在的位置：天下网吧 >> 网吧天地 >> 天下码农 >> 微信小程序 >> 正文

C#中使用Monitor类、Lock和Mutex类来同步多线程的执行

2010-12-30vczx佚名

【大中小】

原文地址：http://blog.csdn.net/tjvictor/archive/2007/01/20/1488290.aspx

在多线程中，为了使数据保持一致性必须要对数据或是访问数据的函数加锁，在数据库中这是很常见的，但是在程序中由于大部分都是单线程的程序，所以没有加锁的必要，但是在多线程中，为了保持数据的同步，一定要加锁，好在Framework中已经为我们提供了三个加锁的机制，分别是Monitor类、Lock关键字和Mutex类。其中Lock关键词用法比较简单，Monitor类和Lock的用法差不多。这两个都是锁定数据或是锁定被调用的函数。而Mutex则多用于锁定多线程间的同步调用。简单的说，Monitor和Lock多用于锁定被调用端，而Mutex则多用锁定调用端。例如下面程序：由于这种程序都是毫秒级的，所以运行下面的程序可能在不同的机器上有不同的结果，在同一台机器上不同时刻运行也有不同的结果，我的测试环境为vs2005, windowsXp , CPU3.0 , 1 G monery。程序中有两个线程thread1、thread2和一个TestFunc函数，TestFunc会打印出调用它的线程名和调用的时间(mm级的)，两个线程分别以30mm和100mm来调用TestFunc这个函数。TestFunc执行的时间为50mm。程序如下：

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading;
namespace MonitorLockMutex
{
class Program
{
  #region variable
  Thread thread1 = null;
  Thread thread2 = null;
  Mutex mutex = null;
  #endregion
  static void Main(string[] args)
  {
   Program p = new Program();
   p.RunThread();
   Console.ReadLine();
  }
  public Program()
  {
   mutex = new Mutex();
   thread1 = new Thread(new ThreadStart(thread1Func));
   thread2 = new Thread(new ThreadStart(thread2Func));
  }
  public void RunThread()
  {
   thread1.Start();
   thread2.Start();
  }
  private void thread1Func()
  {
   for (int count = 0; count < 10; count++)
   {
    TestFunc("Thread1 have run " + count.ToString() + " times");
    Thread.Sleep(30);
   }
  }
  private void thread2Func()
  {
   for (int count = 0; count < 10; count++)
   {
    TestFunc("Thread2 have run " + count.ToString() + " times");
    Thread.Sleep(100);
   }
  }
  private void TestFunc(string str)
  {
   Console.WriteLine("{0} {1}", str, System.DateTime.Now.Millisecond.ToString());
   Thread.Sleep(50);
  }
}
}

运行结果如下：

　可以看出如果不加锁的话，这两个线程基本上是按照各自的时间间隔+TestFunc的执行时间(50mm)对TestFunc函数进行读取。因为线程在开始时需要分配内存，所以第0次的调用不准确，从第1~9次的调用可以看出，thread1的执行间隔约是80mm，thread2的执行间隔约是150mm。现在将TestFunc修改如下：

  private void TestFunc(string str)
  {
   lock (this)
   {
    Console.WriteLine("{0} {1}", str, System.DateTime.Now.Millisecond.ToString());
    Thread.Sleep(50);
   }
  }

或者是用Monitor也是一样的，如下：

  private void TestFunc(string str)
  {
   Monitor.Enter(this);
   Console.WriteLine("{0} {1}", str, System.DateTime.Now.Millisecond.ToString());
   Thread.Sleep(50);
   Monitor.Exit(this);
  }

其中Enter和Exit都是Monitor中的静态方法。运行Lock结果如下：

让我们分析一下结果，同样从第1次开始。相同线程间的调用时间间隔为线程执行时间+TestFunc调用时间，不同线程间的调用时间间隔为TestFunc调用时间。例如：连续两次调用thread1之间的时间间隔约为30+50=80;连续两次调用thread2之间的时间间隔约为100+50=150mm。调用thread1和thread2之间的时间间隔为50mm。因为TestFunc被lock住了，所以一个thread调用TestFunc后，当其它的线程也同时调用TestFunc时，后来的线程即进被排到等待队列中等待，直到拥有访问权的线程释放这个资源为止。这就是锁定被调用函数的特性，即只能保证每次被一个线程调用，线程优先级高的调用的次数就多，低的就少，这就是所谓的强占式。下面让我们看看Mutex类的使用方法，以及与Monitor和Lock的区别。将代码修改如下：

  private void thread1Func()
  {
   for (int count = 0; count < 10; count++)
   {
    mutex.WaitOne();
    TestFunc("Thread1 have run " + count.ToString() + " times");
    mutex.ReleaseMutex();
   }
  }

  private void thread2Func()
  {
   for (int count = 0; count < 10; count++)
   {
    mutex.WaitOne();
    TestFunc("Thread2 have run " + count.ToString() + " times");
    mutex.ReleaseMutex();
   }
  }

  private void TestFunc(string str)
  {
   Console.WriteLine("{0} {1}", str, System.DateTime.Now.Millisecond.ToString());
   Thread.Sleep(50);
  }

运行结果如下：

　　可以看出，Mutex只能互斥线程间的调用，但是不能互斥本线程的重复调用，即thread1中waitOne()只对thread2中的waitOne()起到互斥的作用，但是thread1并不受本wainOne()的影响，可以调用多次，只是在调用结束后调用相同次数的ReleaseMutex()就可以了。　　那么如何使线程按照调用顺序来依次执行呢？其实把lock和Mutex结合起来使用就可以了，改代码如下：

private void thread1Func()
{
for (int count = 0; count < 10; count++)
{
  lock (this)
  {
   mutex.WaitOne();
   TestFunc("Thread1 have run " + count.ToString() + " times");
   mutex.ReleaseMutex();
  }
}
}

private void thread2Func()
{
for (int count = 0; count < 10; count++)
{
  lock (this)
  {
   mutex.WaitOne();
   TestFunc("Thread2 have run " + count.ToString() + " times");
   mutex.ReleaseMutex();
  }
}
}

欢迎访问最专业的网吧论坛,无盘论坛,网吧经营,网咖管理,网吧专业论坛 https://bbs.txwb.com
关注天下网吧微信/下载天下网吧APP/天下网吧小程序，一起来超精彩

本文来源：vczx 作者：佚名

上一篇文章： C#中使用委托

下一篇文章： Flash+ASP实现电子互动地图在线标注功能

明智PNP无盘如何在工作站中使用A驱   苹果将在iMac和MacBooks中使用自主研发处理器   在迅闪环境中使用英保通网克教程
明智PNP无盘如何在工作站中使用A驱   Win8中使用屏幕保护程序   微软拟在WP8中使用诺基亚地图服务
支持资源搜索  在迅雷7中使用新浪微博   使用Visual C#实现断点续传   C#中的特性(Attributes)
Word2010中使用Tab键输入多级编号列表

推荐专题 ┊ 更多专题..

网吧卫生

网吧电脑配置

开网吧

网吧键盘

网吧配置

网吧GHOST

ROS

网吧软件故障解决

网众无盘

网吧游戏菜单

网吧活动

网吧优化

网吧精品

网吧新手

声明

声明：本站所发表的文章、评论及图片仅代表作者本人观点，与本站立场无关。若文章侵犯了您的相关权益，请及时与我们联系，我们会及时处理，感谢您对本站的支持！联系邮箱：support@txwb.com，系统开号，技术支持，服务联系QQ：1175525021本站所有有注明来源为天下网吧或天下网吧论坛的原创作品，各位转载时请注明来源链接！

天下网吧网吧天下

C#中使用Monitor类、Lock和Mutex类来同步多线程的执行

推荐文章

最新文章