MFC CCriticalSection 关键段

大家好，又见面了，我是你们的朋友全栈君。

 和其他同步对象不同，除非有需要以外，关键区域工作在用户模式下。若一个线程想运行一个封装在关键区域中的代码，它首先做一个旋转封锁，然后等待特定的时间，它进入内核模式去等待关键区域。

实际上，关键区域持有一个旋转计数器和一个信号量，前者用于用户模式的等待，后者用于内核模式的等待（休眠态）。在Win32API中，有一个CRITICAL_SECTION结构体表示关键区域对象。在MFC中，有一个类CCriticalSection。关键区域是这样一段代码，当它被一个线程执行时，必须确保不会被另一个线程中断。

一个简单的例子是多个线程共用一个Vector ：

1 一个线程写入vector数据

2 一个读出vector数据

由于之前学习过Win32API中，CRITICAL_SECTION（对MFC关键段理论不加概述怕误导各位！），所以下面直接给出Demo！

也可下载源码：链接地址

不清楚demo的也可交流，

邮箱：sywaries@sina.cn

头文件：CCriticalSectionDlg.h

// CCriticalSectionDlg.h : 头文件
//

#pragma once
#include "afxwin.h"


// CCCriticalSectionDlg 对话框
class CCCriticalSectionDlg : public CDialogEx
{
// 构造
public:
	CCCriticalSectionDlg(CWnd* pParent = NULL);	// 标准构造函数

// 对话框数据
	enum { IDD = IDD_CCRITICALSECTION_DIALOG };

	protected:
	virtual void DoDataExchange(CDataExchange* pDX);	// DDX/DDV 支持


// 实现
protected:
	HICON m_hIcon;

	// 生成的消息映射函数
	virtual BOOL OnInitDialog();
	afx_msg void OnSysCommand(UINT nID, LPARAM lParam);
	afx_msg void OnPaint();
	afx_msg HCURSOR OnQueryDragIcon();
	DECLARE_MESSAGE_MAP()

public:
	static UINT Write(PVOID pParam);
	static UINT Read(PVOID pParam);
	CEdit c_EditWrite;
	CEdit c_EditRead;
public:
	afx_msg void OnBnClickedButStarrt();
};

头文件 实现CCriticalSectionDlg.cpp

// CCriticalSectionDlg.cpp : 实现文件
//

#include "stdafx.h"
#include "CCriticalSection.h"
#include "CCriticalSectionDlg.h"
#include "afxdialogex.h"
#include <vector>
#include <iostream>
using namespace std;

std::vector<int> vec_int;
std::vector<int>::iterator vec_iter;
CCriticalSection cs;

#ifdef _DEBUG
#define new DEBUG_NEW
#endif


// 用于应用程序“关于”菜单项的 CAboutDlg 对话框

class CAboutDlg : public CDialogEx
{
public:
	CAboutDlg();

// 对话框数据
	enum { IDD = IDD_ABOUTBOX };

	protected:
	virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV 支持

// 实现
protected:
	DECLARE_MESSAGE_MAP()
};

CAboutDlg::CAboutDlg() : CDialogEx(CAboutDlg::IDD)
{
}

void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialogEx::DoDataExchange(pDX);
}

BEGIN_MESSAGE_MAP(CAboutDlg, CDialogEx)
END_MESSAGE_MAP()


// CCCriticalSectionDlg 对话框




CCCriticalSectionDlg::CCCriticalSectionDlg(CWnd* pParent /*=NULL*/)
	: CDialogEx(CCCriticalSectionDlg::IDD, pParent)
{
	m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}

void CCCriticalSectionDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialogEx::DoDataExchange(pDX);
	DDX_Control(pDX, IDC_EDIT_WRITE, c_EditWrite);
	DDX_Control(pDX, IDC_EDIT_READ, c_EditRead);
}

BEGIN_MESSAGE_MAP(CCCriticalSectionDlg, CDialogEx)
	ON_WM_SYSCOMMAND()
	ON_WM_PAINT()
	ON_WM_QUERYDRAGICON()
	ON_BN_CLICKED(IDC_BUT_STARRT, &CCCriticalSectionDlg::OnBnClickedButStarrt)
END_MESSAGE_MAP()


// CCCriticalSectionDlg 消息处理程序

BOOL CCCriticalSectionDlg::OnInitDialog()
{
	CDialogEx::OnInitDialog();

	// 将“关于...”菜单项添加到系统菜单中。

	// IDM_ABOUTBOX 必须在系统命令范围内。
	ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
	ASSERT(IDM_ABOUTBOX < 0xF000);

	CMenu* pSysMenu = GetSystemMenu(FALSE);
	if (pSysMenu != NULL)
	{
		BOOL bNameValid;
		CString strAboutMenu;
		bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);
		ASSERT(bNameValid);
		if (!strAboutMenu.IsEmpty())
		{
			pSysMenu->AppendMenu(MF_SEPARATOR);
			pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
		}
	}

	// 设置此对话框的图标。当应用程序主窗口不是对话框时，框架将自动
	//  执行此操作
	SetIcon(m_hIcon, TRUE);			// 设置大图标
	SetIcon(m_hIcon, FALSE);		// 设置小图标

	// TODO: 在此添加额外的初始化代码

	return TRUE;  // 除非将焦点设置到控件，否则返回 TRUE
}

void CCCriticalSectionDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
	if ((nID & 0xFFF0) == IDM_ABOUTBOX)
	{
		CAboutDlg dlgAbout;
		dlgAbout.DoModal();
	}
	else
	{
		CDialogEx::OnSysCommand(nID, lParam);
	}
}

// 如果向对话框添加最小化按钮，则需要下面的代码
//  来绘制该图标。对于使用文档/视图模型的 MFC 应用程序，
//  这将由框架自动完成。

void CCCriticalSectionDlg::OnPaint()
{
	if (IsIconic())
	{
		CPaintDC dc(this); // 用于绘制的设备上下文

		SendMessage(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);

		// 使图标在工作区矩形中居中
		int cxIcon = GetSystemMetrics(SM_CXICON);
		int cyIcon = GetSystemMetrics(SM_CYICON);
		CRect rect;
		GetClientRect(&rect);
		int x = (rect.Width() - cxIcon + 1) / 2;
		int y = (rect.Height() - cyIcon + 1) / 2;

		// 绘制图标
		dc.DrawIcon(x, y, m_hIcon);
	}
	else
	{
		CDialogEx::OnPaint();
	}
}

//当用户拖动最小化窗口时系统调用此函数取得光标
//显示。
HCURSOR CCCriticalSectionDlg::OnQueryDragIcon()
{
	return static_cast<HCURSOR>(m_hIcon);
}

UINT CCCriticalSectionDlg::Write( PVOID pParam )
{
	cs.Lock();
	CString s =_T("写进vector");
	CEdit *cEdit = (CEdit*)pParam;
	for (int i = 0; i<5; i++)
	{
		vec_int.push_back(i);
		
		CString str;
		int b = vec_int.at(i);
		str.Format(_T("%d"),b);
		cEdit->SetWindowTextW(s+"   "+ str);	
		Sleep(500);
	}
	cs.Unlock();

	return 0;
}

UINT CCCriticalSectionDlg::Read( PVOID pParam )
{
	cs.Lock();
	CString s =_T("写出vector");
	CEdit *cEdit = (CEdit*)pParam;
	for (int i = 0; i<5; i++)
	{
		CString str_read;
		int c =vec_int.at(i);
		str_read.Format(_T("%d"), c);
		cEdit->SetWindowTextW(s +"   "+str_read);
		Sleep(500);
	}

	/*for (; vec_int.cbegin() < vec_int.end(); vec_iter++)
	{
	CString str_read;
	int c =vec_int.at(5);
	str_read.Format(_T("%d"), c);
	cEdit->SetWindowTextW(str_read);
	Sleep(500);
	}*/
	cs.Unlock();
	return 0;
}



void CCCriticalSectionDlg::OnBnClickedButStarrt()
{
	// TODO: 在此添加控件通知处理程序代码
	CWinThread *pWrite = AfxBeginThread(Write, &c_EditWrite, THREAD_PRIORITY_NORMAL,0, CREATE_SUSPENDED );
	pWrite->ResumeThread();
	CWinThread *pRead = AfxBeginThread(Read, &c_EditRead, THREAD_PRIORITY_NORMAL,0, CREATE_SUSPENDED );
	pRead->ResumeThread();
}

运行效果如下：