www.pudn.com > Thread3_23.rar > 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); 
}