ThreadTest3.rar_线程同步

// 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); }