线程之间和进程之间的同步

秒速五厘米 2022-08-10 15:57 306阅读 0赞

**今天学习的内容为：利用互斥事件来控制线程之间、进程之间的同步问题。**

其实，进程之间的同步也就类似于线程之间的同步。互斥事件的作用就是为了保证任一个时间内，只有一个线程对对公共资源进行操作。

首先，需要定义一个互斥事件。HANDLE hMutex=CreateMutex(NULL,FALSE,"Mutex")；前两个参数记住就行了，如果想要深究自己去看相关的资料，第三个参数为互斥事件的名称。记住这个互斥事件名称Mutex是无论在线程之间，还是进程之间都是唯一的。可以在其他的进程中通过HANDLE hMutex=OpenMutex(MUTEX\_ALL\_ACCESS,TRUE,"Mutex")；打开这个互斥事件，进行进程之间的同步。第一个参数为控制方式，第二个参数为是否希望子进程能够继承句柄，则为TRUE，第三个则为互斥事件的名称。

下面来看一下线程之间的同步，如果是在一个进程内的线程同步问题的话。这样的例子很多，我就举一个最简单的，线程之间依次输出，如果有两个以上也是依次输出一个线程。顺序是依据你创建线程的顺序。

UINT CThreadDlg::thread1(LPVOID lpParam)
    {
    	CThreadDlg *pThreadDlg=(CThreadDlg *)lpParam;
    	while(1)
    	{
    	    DWORD dReturn=WaitForSingleObject(pThreadDlg->hMutex,INFINITE);//等待信号，第一个为互斥事件句柄，第二个为等待时间
    	    pThreadDlg->GetDlgItem(IDC_EDIT1)->SetWindowText("线程1");
    	    Sleep(1000);
    	    ReleaseMutex(pThreadDlg->hMutex);//释放互斥事件,执行线程2中waitfor的内容
    	}
    	return 0;
    }
    
    UINT CThreadDlg::thread2(LPVOID lpParam)
    {
    	CThreadDlg *pThreadDlg=(CThreadDlg *)lpParam;
    	while(1)
    	{
    	    DWORD dReturn=WaitForSingleObject(pThreadDlg->hMutex,INFINITE);
    	    pThreadDlg->GetDlgItem(IDC_EDIT1)->SetWindowText("线程2");
    	    Sleep(1000);
    	    ReleaseMutex(pThreadDlg->hMutex);
    	}
    	return 0;
    }
    
    void CThreadDlg::OnStart() 
    {
    	// TODO: Add your control notification handler code here
    	hMutex=CreateMutex(NULL,FALSE,"mutex");//创建互斥事件
    	CWnd *pParam=AfxGetMainWnd();//获取窗口句柄
    	CWinThread *pThread1=AfxBeginThread(thread1,pParam,THREAD_PRIORITY_NORMAL);//新建线程
    	CWinThread *pThread2=AfxBeginThread(thread2,pParam,THREAD_PRIORITY_NORMAL);
    }

以上，为一个进程内线程之间同步，如果是进程之间也是同样的方法，只需通过OpenMutex函数即可。

首先，我们在进程1中新建一个线程：

UINT CTempDlg::threadtest(LPVOID lpParam)
    {
    	CTempDlg *pParam=(CTempDlg *)lpParam;
    	HANDLE hmutex=CreateMutex(NULL,FALSE,"testmutex");//新建互斥事件
    	if(hmutex==0) AfxMessageBox("error");
    	int i=0;
    	while(1)
    	{
    		WaitForSingleObject(hmutex,INFINITE);
                    i++;
    	        CString strtemp;
    	        strtemp.Format(" %d",i);
                    pParam->GetDlgItem(IDC_EDIT1)->SetWindowText(strtemp);
    		ReleaseMutex(hmutex);
    		Sleep(1000);
    	}
    	return 0;
    }

然后，在进程2中打开该互斥事件

UINT CThreadDlg::thread3(LPVOID lpParam)
    {
    	CThreadDlg *pThreadDlg=(CThreadDlg *)lpParam;
    	while(1)
    	{
    		DWORD dReturn=WaitForSingleObject(pThreadDlg->hMutex,INFINITE);
    		i+=1;
    		CString str;
    		str.Format("线程3：%d",i);
    		pThreadDlg->GetDlgItem(IDC_EDIT1)->SetWindowText(str);
    		Sleep(5000);
    		ReleaseMutex(pThreadDlg->hMutex);
    	}
    	return 0;
    }
    
    void CThreadDlg::OnButton1() 
    {
    	// TODO: Add your control notification handler code here
    	CWnd *pParam=AfxGetMainWnd();
    	hMutex=OpenMutex(MUTEX_ALL_ACCESS,TRUE,"testmutex");//打开互斥事件，
    
    	if (hMutex==0)//看是否存在，如果不存在则会报错
    	{
    		int error=GetLastError();
    		AfxMessageBox("error");
    		return ;
    	}
    	AfxBeginThread(thread3,pParam);
    }

在这里，如果只运行进程1，则进程1每隔1S输出一次。如果运行了进程2，则进程1就会每隔5S运行一次。