📄 mysyn1view.cpp
字号:
// MySyn1View.cpp : implementation of the CMySyn1View class
//
#include "stdafx.h"
#include "MySyn1.h"
#include "MySyn1Doc.h"
#include "MySyn1View.h"
#include "afxmt.h"
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
#define test1 //使用临界区对象进行线程同步
//#define test2 //使用互斥对象 (mutexse) 进行线程同步
//#define test3 //使用信号量(semaphores)对象进行线程同步
int count=0;
#ifdef test1
CCriticalSection critical;
#endif
#ifdef test2
CMutex mutex;
#endif
#ifdef test3
CSemaphore *sema=new CSemaphore(2,2);
#endif
/////////////////////////////////////////////////////////////////////////////
// CMySyn1View
IMPLEMENT_DYNCREATE(CMySyn1View, CView)
BEGIN_MESSAGE_MAP(CMySyn1View, CView)
//{{AFX_MSG_MAP(CMySyn1View)
ON_COMMAND(ID_Synchro, OnSynchro)
ON_COMMAND(ID_Nonsyn, OnNonsyn)
//}}AFX_MSG_MAP
// Standard printing commands
ON_COMMAND(ID_FILE_PRINT, CView::OnFilePrint)
ON_COMMAND(ID_FILE_PRINT_DIRECT, CView::OnFilePrint)
ON_COMMAND(ID_FILE_PRINT_PREVIEW, CView::OnFilePrintPreview)
END_MESSAGE_MAP()
/////////////////////////////////////////////////////////////////////////////
// CMySyn1View construction/destruction
CMySyn1View::CMySyn1View()
{
// TODO: add construction code here
}
CMySyn1View::~CMySyn1View()
{
}
BOOL CMySyn1View::PreCreateWindow(CREATESTRUCT& cs)
{
// TODO: Modify the Window class or styles here by modifying
// the CREATESTRUCT cs
return CView::PreCreateWindow(cs);
}
/////////////////////////////////////////////////////////////////////////////
// CMySyn1View drawing
void CMySyn1View::OnDraw(CDC* pDC)
{
CMySyn1Doc* pDoc = GetDocument();
ASSERT_VALID(pDoc);
// TODO: add draw code for native data here
}
/////////////////////////////////////////////////////////////////////////////
// CMySyn1View printing
BOOL CMySyn1View::OnPreparePrinting(CPrintInfo* pInfo)
{
// default preparation
return DoPreparePrinting(pInfo);
}
void CMySyn1View::OnBeginPrinting(CDC* /*pDC*/, CPrintInfo* /*pInfo*/)
{
// TODO: add extra initialization before printing
}
void CMySyn1View::OnEndPrinting(CDC* /*pDC*/, CPrintInfo* /*pInfo*/)
{
// TODO: add cleanup after printing
}
/////////////////////////////////////////////////////////////////////////////
// CMySyn1View diagnostics
#ifdef _DEBUG
void CMySyn1View::AssertValid() const
{
CView::AssertValid();
}
void CMySyn1View::Dump(CDumpContext& dc) const
{
CView::Dump(dc);
}
CMySyn1Doc* CMySyn1View::GetDocument() // non-debug version is inline
{
ASSERT(m_pDocument->IsKindOf(RUNTIME_CLASS(CMySyn1Doc)));
return (CMySyn1Doc*)m_pDocument;
}
#endif //_DEBUG
/////////////////////////////////////////////////////////////////////////////
// CMySyn1View message handlers
UINT NonsynFunction(LPVOID param)
{ int Data[5],i;
for(i=0;i<3;i++)
{count++;
::Sleep(50);
Data[i]=count;
}
char str[50]={0};
for(i=0;i<3;i++)
{int len=strlen(str);
wsprintf(&str[len],"%d",Data[i]);
}
::MessageBox((HWND)param,str,"Nonsyn Thread",MB_OK);
return 0;
}
UINT SynchroFunction(LPVOID param)
{ int Data[5],i;
#ifdef test1
critical.Lock();
#endif
#ifdef test2
CSingleLock singleLock(&mutex);
singleLock.Lock();
#endif
#ifdef test3
CSingleLock singleLock(sema);
singleLock.Lock();
#endif
for(i=0;i<3;i++)
{count++;
::Sleep(50);
Data[i]=count;
}
char str[50]={0};
for(i=0;i<3;i++)
{int len=strlen(str);
wsprintf(&str[len],"%d",Data[i]);
}
::Sleep(5000);
#ifdef test1
critical.Unlock();
#endif
#ifdef test2
singleLock.Unlock();
#endif
#ifdef test3
singleLock.Unlock();
#endif
::MessageBox((HWND)param,str,"synchro Thread",MB_OK);
return 0;
}
void CMySyn1View::OnNonsyn()
{
// TODO: Add your command handler code here
count=0;
HWND hWnd=GetSafeHwnd();
AfxBeginThread(NonsynFunction,hWnd);
AfxBeginThread(NonsynFunction,hWnd);
AfxBeginThread(NonsynFunction,hWnd);
}
void CMySyn1View::OnSynchro()
{
// TODO: Add your command handler code here
count=0;
HWND hWnd=GetSafeHwnd();
AfxBeginThread(SynchroFunction,hWnd);
AfxBeginThread(SynchroFunction,hWnd);
AfxBeginThread(SynchroFunction,hWnd);
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -