thread3view.cpp

本代码演示了利用临界区实现线程的同步。

// Thread3View.cpp : implementation of the CThread3View class
//

#include "stdafx.h"
#include "Thread3.h"

#include "Thread3Doc.h"
#include "Thread3View.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

//////////////////////////////////////////////////////////////////////////////
//CDataArray

void CDataArray::SetData(int iValue)
{
	CSingleLock SingleLock(&Mutex);
	SingleLock.Lock();
	for (int i=0;i<10;i++)
		iArray[i]=iValue;
}

void CDataArray::GetDataArray(int aArray[10])
{
	CSingleLock SingleLock(&Mutex);
	SingleLock.Lock();
	for (int i=0;i<10;i++)
		aArray[i]=iArray[i];
}

/////////////////////////////////////////////////////////////////////////////
// CThread3View

IMPLEMENT_DYNCREATE(CThread3View, CScrollView)

BEGIN_MESSAGE_MAP(CThread3View, CScrollView)
	//{{AFX_MSG_MAP(CThread3View)
	ON_COMMAND(ID_THREAD_BEGIN, OnThreadBegin)
	//}}AFX_MSG_MAP
	// Standard printing commands
	ON_COMMAND(ID_FILE_PRINT, CScrollView::OnFilePrint)
	ON_COMMAND(ID_FILE_PRINT_DIRECT, CScrollView::OnFilePrint)
	ON_COMMAND(ID_FILE_PRINT_PREVIEW, CScrollView::OnFilePrintPreview)
END_MESSAGE_MAP()

CDataArray	DataArray;
/////////////////////////////////////////////////////////////////////////////
// CThread3View construction/destruction

CThread3View::CThread3View()
{
	// TODO: add construction code here

}

CThread3View::~CThread3View()
{
}

BOOL CThread3View::PreCreateWindow(CREATESTRUCT& cs)
{
	// TODO: Modify the Window class or styles here by modifying
	//  the CREATESTRUCT cs

	return CScrollView::PreCreateWindow(cs);
}

/////////////////////////////////////////////////////////////////////////////
// CThread3View drawing

void CThread3View::OnDraw(CDC* pDC)
{
	CThread3Doc* pDoc = GetDocument();
	ASSERT_VALID(pDoc);
	// TODO: add draw code for native data here
	LOGFONT logFont;
	logFont.lfHeight=24;
	logFont.lfWeight=FW_BOLD;
	logFont.lfOrientation=0;
	logFont.lfEscapement=0;
	logFont.lfStrikeOut=0;
	logFont.lfUnderline=0;
	logFont.lfItalic=0;
	logFont.lfCharSet=GB2312_CHARSET;
	logFont.lfOutPrecision=OUT_DEFAULT_PRECIS;
	logFont.lfClipPrecision=CLIP_DEFAULT_PRECIS;
	logFont.lfQuality=DEFAULT_QUALITY;
	logFont.lfPitchAndFamily=DEFAULT_PITCH|FF_ROMAN;
	strcpy(logFont.lfFaceName,"The Times Roman");

	CFont font;
	font.CreateFontIndirect(&logFont);
	CFont* oldFont=pDC->SelectObject(&font);

	CRect Rect;
	GetClientRect(&Rect);
	pDC->SetTextColor(RGB(255,0,0));
	pDC->DrawText("线程同步--使用互斥",Rect,DT_CENTER|DT_VCENTER|DT_SINGLELINE);


	pDC->SelectObject(oldFont);

}

void CThread3View::OnInitialUpdate()
{
	CScrollView::OnInitialUpdate();

	CSize sizeTotal;
	// TODO: calculate the total size of this view
	sizeTotal.cx = sizeTotal.cy = 100;
	SetScrollSizes(MM_TEXT, sizeTotal);
}

/////////////////////////////////////////////////////////////////////////////
// CThread3View printing

BOOL CThread3View::OnPreparePrinting(CPrintInfo* pInfo)
{
	// default preparation
	return DoPreparePrinting(pInfo);
}

void CThread3View::OnBeginPrinting(CDC* /*pDC*/, CPrintInfo* /*pInfo*/)
{
	// TODO: add extra initialization before printing
}

void CThread3View::OnEndPrinting(CDC* /*pDC*/, CPrintInfo* /*pInfo*/)
{
	// TODO: add cleanup after printing
}

/////////////////////////////////////////////////////////////////////////////
// CThread3View diagnostics

#ifdef _DEBUG
void CThread3View::AssertValid() const
{
	CScrollView::AssertValid();
}

void CThread3View::Dump(CDumpContext& dc) const
{
	CScrollView::Dump(dc);
}

CThread3Doc* CThread3View::GetDocument() // non-debug version is inline
{
	ASSERT(m_pDocument->IsKindOf(RUNTIME_CLASS(CThread3Doc)));
	return (CThread3Doc*)m_pDocument;
}
#endif //_DEBUG

/////////////////////////////////////////////////////////////////////////////
// CThread3View message handlers


////////////////////////////////////////////////////////////////////////////
//线程函数

UINT Thread_WriteProc(LPVOID param)
{
	for (int i=0;i<10;i++)
	{
		DataArray.SetData(i);
		::Sleep(500);
	}
	return 0;
}

UINT Thread_ReadProc(LPVOID param)
{
	int aArray[10];
	for (int i=0;i<20;i++)
	{
		DataArray.GetDataArray(aArray);
		char str[255];
		str[0]=0;
		for (int j=0;j<10;j++)
		{
			int len=strlen(str);
			wsprintf(&str[len],"%d",aArray[j]);
		}
		::MessageBox((HWND)param,str,"Thread Read Proc",MB_OK);
	}
	return 0;
}

void CThread3View::OnThreadBegin() 
{
	// TODO: Add your command handler code here
	HWND hWnd=GetSafeHwnd();
	AfxBeginThread(Thread_WriteProc,hWnd);
	AfxBeginThread(Thread_ReadProc,hWnd);
}