学习多线程之四：线程同步--使用信号量

学习多线程之四：线程同步--使用信号量
作者：

除了使用临界区与互斥可以完成线程间的同步外，还可以使用信号量CSemaphore。使用信号量还有一个好处便是：信号允许多个线程同时使用共享资源，这便与操作系统中的PV操作有些雷同的地方。它指出了同时访问共享资源的线程最大数目。

在信号量内部有一个计数器，当有线程访问共享资源时，计数器将自动递减，当它为0时，不再允许其他线程对共享资源的访问，直到有一个线程释放共享资源，从而完成对共享资源的保护。



在建立一个信号量时必须提供一个初始化值和一个最大计数值，如：

CSemaphore Semaphore(2,2);

可以在类的构造函数中动态地创建CSemaphore对象，如：

Semaphore=new CSemaphore(2,2);

信号量CSemaphore被建立后，就可以准备用它来对共享资源进行访问计数。要完成计数处理，首先应建立一个CSingleLock或CMultiLock对象，如：

CSingleLock SingleLock(Semaphore);

要减小这个信号Semaphore的计数值，只须调用CSingleLock对象的成员函数Lock()即可：

SingleLock.Lock();

同样，通过调用UnLock()来释放这个信号量，即：

SingleLock.UnLock();

从而我们可这样来申明类：

#include "afxmt.h"

class CSharedResource
{
private:
	CSemaphore* ptrSemaphore;
public:
	CSharedResource();
	~CSharedResource();
  
	void AccessResource();
};

在构造函数中完成对信号对象的创建：

CSharedResource::CSharedResource()
{
	ptrSemaphore=new CSemaphore(2,2);
}

在析构函数中完成对信号对象的释放：

CSharedResource::~CSharedResource()
{
	delete ptrSemaphore;
}

用以下过程来访问共享资源：

void CSharedResource::AccessResource()
{
	CSingleLock SingleLock(ptrSemaphore);
	SingleLock.Lock();
	/* ......
	  资源访问
	*/
	Sleep(1000);
}

再建立使用信号量的线程函数：

UINT Thread_Proc1(LPVOID param)
{
	SharedResource.AccessResource();
	::MessageBox((HWND)param,"Thread #1 had accessed the Semaphore!","Thread Proc1",MB_OK);
	return 0;
}

UINT Thread_Proc2(LPVOID param)
{
	SharedResource.AccessResource();
	::MessageBox((HWND)param,"Thread #2 had accessed the Semaphore!","Thread Proc2",MB_OK);
	return 0;
}

UINT Thread_Proc3(LPVOID param)
{
	SharedResource.AccessResource();
	::MessageBox((HWND)param,"Thread #3 had accessed the Semaphore!","Thread Proc3",MB_OK);
	return 0;
}

再用以下代码执行各个线程函数：

HWND hWnd=GetSafeHwnd();
AfxBeginThread(Thread_Proc1,hWnd);
AfxBeginThread(Thread_Proc2,hWnd);
AfxBeginThread(Thread_Proc3,hWnd);

这样当Thread_Proc1和Thread_Proc2占用信号量之后，只有等其中一个释放信号量之后，Thread_Proc3方可占用信号量，达到了线程之间资源的保护，实现数据共享!

本文即本人在学习多任务多线程过程的手记，供大家参考，望能得到各位指点。
作者信箱：[e-mail]

--------------------next---------------------

写得不错，挺清楚的，使用sleep（）是为了让大家能够清楚的看到窗口蹦出的过程，如果不使用sleep，三个窗口一下子就全部蹦出来了，不易于程序理解。此设计真是用心良苦。
在这里不得不提一下的是，谦虚使人进步，对别人的心血妄加负面评论是不明智的——缺德。 ( hgkx 发表于 2006-11-3 14:48:00)
 
任何一个发文章的作者都应该被尊重。
如果有错误，大家一起讨论修正，共同进步。 ( only2004 发表于 2006-5-11 16:36:00)
 
我真不明白.它的4篇文章至少有2,3篇都有错误,代码根本无法实现同步.竟然还能被选中进入知识库? ( greenjava 发表于 2005-7-11 13:03:00)
 
：－)
感谢你教会了我使用 CSemaphore

:-(
CSemaphore Semaphore(2,2);
信口雌黄
error C2059: syntax error : 'constant'
负责点好不
( windcao 发表于 2004-1-8 10:56:00)
 
我特讨厌有些人的说话方式，好像自己就特nb的那种，为什么看不到别人的优点和长处？ ( BadChen 发表于 2003-8-24 11:31:00)
 
程序太烂了，你的线程根据就没有同步
void CSharedResource::AccessResource()
{
CSingleLock SingleLock(ptrSemaphore);
SingleLock.Lock();
/* ......
  资源访问
*/
Sleep(1000);
}
你为了一个窗口访问一个资源用了Sleep(1000)，如果我在弹出两个窗口后，等一秒钟，必有一个或两个资源释放，等三个窗口就出来了，所以这样是不行的。
你应该是在窗口中，这样操作。
CSingleLock SingleLock(Semaphore);
SingleLock.Lock()
::MessageBox(...);
SingleLock.Unlock();
( shewo 发表于 2003-8-18 11:11:00)
 
不错，谢谢！

有个小问题感到奇怪：为什么3个对话框弹出的顺序为2，1，3，而不是1，2，3 ( zxyin4 发表于 2003-7-9 14:16:00)
 
.......................................................

--------------------next---------------------