WEB开发网      婵犵數濞€濞佳囧磹婵犳艾鐤炬い鎰堕檮閸嬬喐銇勯弽銊с€掗梻鍕閺岋箑螣娓氼垱笑闂佽姘﹂褔婀佸┑鐘诧工妤犲憡绂嶉崜褏纾奸弶鍫涘妼缁楁岸鏌熷畡鐗堝殗闁诡喒鏅犲畷褰掝敃閵堝棙顔忔繝鐢靛仦閸ㄥ爼骞愰幘顔肩;闁规崘绉ぐ鎺撳亹闁绘垶锕╁Λ鍕⒑閹肩偛濡奸悗娑掓櫇缁顓兼径妯绘櫇闂佹寧绻傞弻濠囨晝閸屾稓鍘甸柣搴㈢⊕閿氶柣蹇ョ稻缁绘繃绻濋崘銊т紝闂佽鍨伴崯鏉戠暦閻旂⒈鏁傞柛鈾€鏅欑槐妯衡攽閻愬樊鍤熷┑顔藉劤铻為柛鏇ㄥ墯閸欏繘鏌嶉崫鍕櫣缂佲偓婢跺绠鹃柟瀛樼箘閿涘秵顨ラ悙顏勭伈闁诡喖缍婂畷鎯邦槻婵℃彃顭烽弻娑㈠Ω閵夈儺鍔夌紓浣稿€哥粔褰掑极閹剧粯鏅搁柨鐕傛嫹 ---闂傚倷鐒︾€笛兠洪埡鍛闁跨噦鎷�
开发学院软件开发VC 线程同步--使用信号量 阅读

线程同步--使用信号量

 2006-07-20 11:37:36 来源:WEB开发网 闂傚倷绶氬ḿ褍螞閹绢喖绠柨鐕傛嫹闂傚倷绀侀幉锟犲垂閻㈠灚宕查柟鎵閸庡秵銇勯幒鎴濃偓鐢稿磻閹炬枼妲堟繛鍡楃С濞岊亞绱撻崒姘扁枌闁瑰嚖鎷�婵犵數濮幏鍐川椤撴繄鎹曢梻渚€娼уú銈吤洪妸鈺佺劦妞ゆ帊鑳堕埊鏇㈡煏閸モ晛浠х紒杈╁仱閺佹捇鏁撻敓锟�闂傚倷绶氬ḿ褍螞閹绢喖绠柨鐕傛嫹  闂傚倷鑳舵灙缂佺粯顨呴埢宥夊即閵忕姵鐎梺缁樺姇閹碱偆鐥閺屾洘绻濊箛鏇犵獥闂佺厧澹婃禍婊堚€旈崘顏佸亾閿濆骸澧ù鐘欏嫮绠鹃柛顐ゅ枎閻忋儲銇勯弴妯哄姦妞ゃ垺鐟╅幃鈩冩償閵囧府鎷�
核心提示:本文示例源代码或素材下载 除了使用临界区与互斥可以完成线程间的同步外,还可以使用信号量CSemaphore,线程同步--使用信号量,使用信号量还有一个好处便是:信号允许多个线程同时使用共享资源,这便与操作系统中的PV操作有些雷同的地方,实现数据共享!本文即本人在学习多任务多线程过程的手记,供大家参考,它指出了同

本文示例源代码或素材下载

除了使用临界区与互斥可以完成线程间的同步外,还可以使用信号量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方可占用信号量,达到了线程之间资源的保护,实现数据共享!

本文即本人在学习多任务多线程过程的手记,供大家参考,望能得到各位指点。

Tags:线程 同步 使用

编辑录入:爽爽 [复制链接] [打 印]
赞助商链接