技术开发 频道

.NET多线程同步方法详解


   其实对于OpenExisting函数有两个重载版本,
   Mutex.OpenExisting (String)
   Mutex.OpenExisting (String, MutexRights) 
   对于默认的第一个函数其实是实现了第二个函数 MutexRights.Synchronize|MutexRights.Modify操作。

    由于监视器的设计是基于.Net框架,而Mutex类是系统内核对象封装了win32的一个内核结构来实现互斥,并且互斥操作需要请求中断来完成,因此在进行进程内线程同步的时候性能上要比互斥要好。

    典型的使用Mutex同步需要完成三个步骤的操作:1.打开或者创建一个Mutex实例;2.调用WaitOne()来请求互斥对象;3.最后调用ReleaseMutex来释放互斥对象。

static public void AddString(string str) 
{
// 设置超时时限并在wait前退出非默认托管上下文
if (_mtx.WaitOne(1000, true))
{
_resource.Add(str);
_mtx.ReleaseMutex();
}
}
    需要注意的是,WaitOne和ReleaseMutex必须成对出现,否则会导致进程死锁的发生,这时系统(.Net2.0)框架会抛出AbandonedMutexException异常。

信号量(Semaphore)

    信号量就像一个夜总会:它有确切的容量,并被保镖控制。一旦满员,就没有人能再进入,其他人必须在外面排队。那么在里面离开一个人后,队头的人就可以进入。信号量的构造函数需要提供至少两个参数-现有的人数和最大的人数。
信号量的行为有点类似于Mutex或是lock,但是信号量没有拥有者。任意线程都可以调用Release来释放信号量而不像Mutex和lock那样需要线程得到资源才能释放。
class SemaphoreTest 
{
static Semaphore s = new Semaphore(3, 3); // 当前值=3; 容量=3

static void Main()
{
for (int i = 0; i < 10; i++) new Thread(Go).Start();
}

static void Go()
{
while (true)
{
s.WaitOne();
Thread.Sleep(100); // 一次只有个线程能被处理
s.Release();
}
}
}


0
相关文章