MFC-线程同步

线程同步有四种方法.

两个简单的线程函数例子:

UINT Thread1(LPVOID lParam)
{
for (int i = 0; i < 10000000;i++)
{
sum++;
}
SetDlgItemInt(AfxGetApp()->m_pMainWnd->m_hWnd, IDC_STATIC,sum,TRUE);
return 0;
}
UINT Thread2(LPVOID lParam)
{
for (int i = 0; i < 10000000; i++)
{
sum++;
}
SetDlgItemInt(AfxGetApp()->m_pMainWnd->m_hWnd, IDC_STATIC, sum, TRUE);
return 0;
}

方法一:使用临界区对象(CCriticalSection类)

1.在构造函数中创建一个临界区对象

g_critical_section = new CCriticalSection();

2.分别给两个(或多个)线程加锁

for (int i = 0; i < 10000000;i++)
{
//加锁
g_critical_section->Lock();
sum++; //当操作共享数据时为了防止同时被操作导致结果错误,
//所以要加锁,这个时候其它线程就不能对这个加锁的数据进程操作,需要等到这个数据解锁才能进程操作
//解锁
g_critical_section->Unlock();
}

3.在析构函数中释放临界区对象

delete g_critical_section;
g_critical_section = nullptr;

这个同步方法相对于其它三种方法是最快的

方法二:使用互斥对象(CMutex类)

1.在构造函数中创建互斥对象

g_mutex = new CMutex();

2.分别给两个(或多个)线程加锁

//利用互斥对象作为参数,创建一个信号锁
CSingleLock singlelock(g_mutex);
for (int i = 0; i < 1000000; i++)
{
//加锁
singlelock.Lock();
//可能加锁失败,要判断是否加锁成功
if (singlelock.IsLocked())
{
sum++; //当操作共享数据时为了防止同时被操作导致结果错误,
//所以要加锁,这个时候其它线程就不能对这个加锁的数据进程操作,需要等到这个数据解锁才能进程操作
//解锁
singlelock.Unlock();
}

}

3.在析构函数中释放互斥对象

delete g_mutex;
g_mutex = nullptr;

这个方法比方法一慢了许多

方法三:使用信号量对象(CSemaphore类)

信号量是CSemaphore的对象，该对象的作用是对访问某个共享资源的线程的数目进行控制。

CSemaphore类的构造函数原型如下：

CSemaphore(
LONG lInitialCount /* = 1 */,    //计数器的初始值
LONG lMaxCount /* = 1 */,        //计数器的最大计数值
LPCTSTR pstrName/* =NULL */,        //信号的名称
LPSECURITY_ATTRIBUTES lpsaAttributes /* = NULL */    //指向一个SECURITY_ATTRIBUTES结构的指针
)

1.在构造函数中创建信号量对象

//因为这个例子只有2个线程,所以计数器只要一个就行
g_semaphore = new CSemaphore(1,1);

2.分别给两个(或多个)线程加锁

//利用信号量对象作为参数,创建一个信号锁
CSingleLock singlelock(g_semaphore);
for (int i = 0; i < 1000000; i++)
{
//加锁
singlelock.Lock();
//可能加锁失败,要判断是否加锁成功
if (singlelock.IsLocked())
{
sum++; //当操作共享数据时为了防止同时被操作导致结果错误,
//所以要加锁,这个时候其它线程就不能对这个加锁的数据进程操作,需要等到这个数据解锁才能进程操作
//解锁
singlelock.Unlock();
}

}

3.在析构函数中释放信号量对象

delete g_semaphore;
g_semaphore = nullptr;

方法4:使用事件对象(CEvent类)

1.在构造函数创建事件对象

g_event = new CEvent(TRUE);

2.分别给两个(或多个)线程加锁

//利用事件对象作为参数,创建一个信号锁
CSingleLock singlelock(g_event);
for (int i = 0; i < 1000000; i++)
{
//加锁
singlelock.Lock();
//可能加锁失败,要判断是否加锁成功
if (singlelock.IsLocked())
{
sum++; //当操作共享数据时为了防止同时被操作导致结果错误,
//所以要加锁,这个时候其它线程就不能对这个加锁的数据进程操作,需要等到这个数据解锁才能进程操作
//解锁
singlelock.Unlock();
g_event->SetEvent();//必须要告诉其它线程本线程已经解锁,你可以加锁了
}

}