多线程实现线程同步~临界区对象

多线程实现线程同步~~临界区对象

 线程同步是指同一进程中的多个线程互相协调工作达到一致。有时在编写程序时，会使多个代码段同时读取或修改相同地址空间中的共享数据。此时，在操作系统中，可能会出现一个代码段在读取数据，另一个代码段在修改数据，这样会导致程序发生读写错误！而解决这样的问题，需要使用线程同步技术。

  临界区对象

  临界区对象，是指当使用某个线程访问共享资源时，必须使代码段独享该资源，不允许其他线程返问该资源。

  这里将分享两种方法，一种是API函数，另一种是MFC类。

API函数：

需要调用函数InitializeCriticalSection对临界区对象进行初始化。

函数原型：

VOID InitializeCriticalSection(
  LPCRITICAL_SECTION lpCriticalSection  // critical section);

参数是一个指向结构体CRITICAL_SECTION的指针变量。

需要调用函数EnterCriticalSection进入临界区。

函数原型：

VOID EnterCriticalSection(
  LPCRITICAL_SECTION lpCriticalSection  // critical section);

参数同上。

需要调用函数LeaveCriticalSection离开临界区。

函数原型：

VOID LeaveCriticalSection(
  LPCRITICAL_SECTION lpCriticalSection   // critical section);

参数同上。

如果调用线程释放临界区的所以权之后，应该使用函数DeleteCriticalSection将临界区从内存中删除。

函数原型：

VOID DeleteCriticalSection(
  LPCRITICAL_SECTION lpCriticalSection   // critical section);

参数同上。

下面是C语言实现：

#include <stdio.h>
#include <windows.h>

DWORD WINAPI myfun1(LPVOID lpParameter);                   //声明线程函数
DWORD WINAPI myfun2(LPVOID lpParameter);
static int a1 = 0;
CRITICAL_SECTION Section1;

int main()
{
	HANDLE h1, h2;
	InitializeCriticalSection(&Section1);                   //初始化临界区对象
	h1 = ::CreateThread(NULL, 0, myfun1, NULL, 0, NULL);   //创建线程
	printf("线程1开始运行!\r\n");
	h2 = ::CreateThread(NULL, 0, myfun2, NULL, 0, NULL);
	printf("线程2开始运行!\r\n");
	::CloseHandle(h1);                                     //关闭线程句柄对象
	::CloseHandle(h2);
	::Sleep(10000);
	printf("按q正常退出!\r\n");
	if(getchar() == 'q')
	{
		DeleteCriticalSection(&Section1);
	}
	else
	{
		return 0;
	}
	return 0;
}
DWORD WINAPI myfun1(LPVOID lpParameter)
{
	while(1)
	{
		EnterCriticalSection(&Section1);        //进入临界区
		::Sleep(1000);
		a1++;
		if(a1 < 1000)
		{
		//	::Sleep(1000);
			printf("线程1正在计数%d\r\n", a1);
			LeaveCriticalSection(&Section1);   //离开临界区
			::Sleep(1000);
		}
		else
		{
			LeaveCriticalSection(&Section1);
			break;
		}
	}
	return 0;
}
DWORD WINAPI myfun2(LPVOID lpParameter)
{
	while(1)
	{
		EnterCriticalSection(&Section1);
		::Sleep(1000);
		a1++;
		if(a1 < 1000)
		{
		//	::Sleep(1000);
			printf("线程2正在计数%d\r\n", a1);
			LeaveCriticalSection(&Section1);
			::Sleep(1000);
		}
		else
		{
			LeaveCriticalSection(&Section1);
			break;
		}
	}
	return 0;
}

结果：

下面的是MFC类：

MFC类用Lock锁定临界区，unLock对临界区进行解锁。

MFC类，需要添加头文件：#include <afxmt.h>

#include <stdio.h>
//#include <windows.h>
#include <afxmt.h>

DWORD WINAPI myfun1(LPVOID lpParameter);                   //声明线程函数
DWORD WINAPI myfun2(LPVOID lpParameter);
int a1 = 0;
CCriticalSection m_sec;

int main()
{
	HANDLE h1, h2;
	h1 = ::CreateThread(NULL, 0, myfun1, NULL, 0, NULL);   //创建线程
	printf("线程1开始运行!\r\n");
	h2 = ::CreateThread(NULL, 0, myfun2, NULL, 0, NULL);
	printf("线程2开始运行!\r\n");
	::CloseHandle(h1);                                     //关闭线程句柄对象
	::CloseHandle(h2);
	::Sleep(5000);
	return 0;
}
DWORD WINAPI myfun1(LPVOID lpParameter)
{
	m_sec.Lock();
	a1++;
	::Sleep(1000);
	printf("线程1正在计数%d\r\n", a1);
	m_sec.Unlock();
	return 0;
}
DWORD WINAPI myfun2(LPVOID lpParameter)
{
	m_sec.Lock();
	a1++;	
	::Sleep(1000);	
	printf("线程2正在计数%d\r\n", a1);
	m_sec.Unlock();
	return 0;
}

结果：

对于多线程，也只是初步的了解，慢慢深入吧！！~~

   InitializeCriticalSection。