当前位置:松语文学 > 其他类型 >VC++_6.0程序设计从入门到精通最新章节 > VC++_6.0程序设计从入门到精通TXT下载
错误举报

第 48 章

  Horse.speed = m_BSpeed.GetPos();

  m_BlueHorse.size = 10;

  m_BlueHorse.rect.TopLeft() = racingrect.TopLeft()+CPoint(0, racingrect.Height()*2/3);

  m_BlueHorse.rect.right = m_BlueHorse.rect.TopLeft().x + racingrect.Width();

  m_BlueHorse.rect.bottom = m_BlueHorse.rect.TopLeft().y + racingrect.Height()/3;

  m_BlueHorse.x = m_BlueHorse.rect.left + m_BlueHorse.size;

  m_BlueHorse.y = m_BlueHorse.rect.top + m_BlueHorse.rect.Height()/2;

  // 创建蓝马线程

  m_hBlue = CreateThread(NULL, 0, ThreadProc, &m_BlueHorse, 0, &tID);

  if(m_hBlue == NULL)

  {

  AfxMessageBox("创建线程失败");

  枫叶文学网www.fywxw.com

  Visual C++ 6.0 程序设计从入门到精通

  ·226·

  }

  }

  // 设置按钮状态

  CButton* pBtn;

  pBtn = (CButton*)GetDlgItem(IDSTART);

  pBtn->EnableWindow(FALSE);

  pBtn = (CButton*)GetDlgItem(IDPAUSE);

  pBtn->EnableWindow(TRUE);

  pBtn = (CButton*)GetDlgItem(IDSTOP);

  pBtn->EnableWindow(TRUE);

  }

  (11)响应“暂停”按钮

  响应“暂停”按钮,用来暂停和继续线程,代码如下:

  void CRacingDlg::OnPause()

  {

  // 得到button 的指针

  CButton* pBtn = (CButton*)GetDlgItem(IDPAUSE);

  // 改变按钮的名称

  if( !m_bPaused )

  {

  SuspendThread(m_hRed);

  SuspendThread(m_hGreen);

  SuspendThread(m_hBlue);

  pBtn->SetWindowText("继续");

  }

  else

  {

  RescomThread(m_hRed);

  RescomThread(m_hGreen);

  RescomThread(m_hBlue);

  枫叶文学网www.fywxw.com

  第9 章 多线程

  ·227·

  pBtn->SetWindowText("暂停");

  }

  // 改变按钮的状态

  m_bPaused = !m_bPaused;

  }

  (12)响应“停止”按钮

  响应“停止”按钮,用来停止线程,代码如下:

  void CRacingDlg::OnStop()

  {

  // TODO: Add your control notification handler code here

  // 存放线程的退出码

  DWORD code;

  if (!GetExitCodeThread(m_hRed, &code) ||

  code == STILL_ACTIVE)

  {

  TerminateThread(m_hRed, code);

  CloseHandle(m_hRed);

  }

  if (!GetExitCodeThread(m_hGreen, &code) ||

  code == STILL_ACTIVE)

  {

  TerminateThread(m_hGreen, code);

  CloseHandle(m_hGreen);

  }

  if (!GetExitCodeThread(m_hBlue, &code) ||

  code == STILL_ACTIVE)

  {

  TerminateThread(m_hBlue, code);

  CloseHandle(m_hBlue);

  }

  // 初始化对话框控件

  InitDlgItem();

  }

  枫叶文学网www.fywxw.com

  Visual C++ 6.0 程序设计从入门到精通

  ·228·

  (13)响应“关闭”按钮

  响应“关闭”按钮,用来停止线程,并且释放资源,代码如下:

  void CRacingDlg::OnCancel()

  {

  // TODO: Add extra cleanup here

  OnStop();

  // 释放Mutex 资源

  CloseHandle(g_hRMutex);

  CloseHandle(g_hGMutex);

  CloseHandle(g_hBMutex);

  CDialog::OnCancel();

  }

  (14)运行结果

  运行程序,单击“开始”按钮,界面如图9-1 所示。

  图9-1 程序开始运行的界面

  调整各个马的速度,并且单击“暂停”按钮,界面如图9-2 所示,这时“暂停”按钮变

  成“继续”按钮。

  枫叶文学网www.fywxw.com

  第9 章 多线程

  ·229·

  图9-2 暂停后的程序界面

  单击“停止”按钮,则重新开始比赛。单击“关闭”按钮,退出程序。

  9.3.4 线程间的通信

  线程间的通信通常采用共享全局变量,共享存储区来实现。因为所有的线程都可以访问

  这些资源。但是需要注意线程的同步,将在下一节做详细介绍。主线程不能通过发送消息给

  辅助线程实现通信,但辅助线程可以通过发送自定义消息达到和主线程通信的目的。本节将

  通过一个简单的实例,介绍使用共享存储区和自定义消息实现线程间通信的功能。

  实例9-2:线程之间通信实例。源代码在光盘中“\09\实例9-2\IPCDemog”目录下。

  (1)创建工程

  首先利用VC++的AppWizard 创建一个基于对话框的应用程序(请参考第四章相关内

  容)。所有设置都采用默认选项。

  (2)添加资源

  为新建的对话框添加一个编辑框控件,用来输入字符。代码如下:

  CEdit m_input;

  (3)添加变量

  给对话框加入内存映shè文件句柄和视图的成员变量,代码如下:

  HANDLE m_hFileMapping; // 内存映shè文件句柄

  LPVOID m_pViewOfFile; // 内存映shè文件视图, 包含输入框的内容

  BOOL m_bNotify; // 只有m_bNotify 为TRUE 时, OnChangeEditBox 才会工作

  枫叶文学网www.fywxw.com

  Visual C++ 6.0 程序设计从入门到精通

  ·230·

  (4)定义消息

  注册自定义的消息WM_MyMessage,代码如下:

  // 注册windows 消息

  const UINT WM_MyMessage = RegisterWindowMessage(_T("MY_IPC_MESSAGE"));

  (5)变量初始化

  初始化内存映shè文件的大小和名称,代码如下:

  // 内存映shè文件的大小

  const DWORD dwMemoryFileSize = 4 * 1024;

  // 内存映shè文件的名字

  const LPCTSTR sMemoryFileNcom = _T("MY_IPC_SHAREMEMORY");

  (6)对话框初始化

  改写对话框的OnInitDialog 函数,进行初始化,代码如下:

  BOOL CIPCDemoDlg::OnInitDialog()

  {

  CDialog::OnInitDialog();

  ……

  // TODO: Add extra initialization here

  // 保证文本框中的文本的大小比内存文件小

  m_input.SetLimitText(dwMemoryFileSize - 1);

  // 创建内存映shè文件

  m_hFileMapping = CreateFileMapping(

  INVALID_HANDLE_VALUE, // 系统页面大小

  NULL, // 安全属xìng

  PAGE_READWRITE, // 保护方式

  0, // 大小变量的高字节

  dwMemoryFileSize*sizeof(TCHAR), // 大小变量的低字节

  sMemoryFileNcom // 文件名称

  );

  DWORD dwError = GetLastError();

  if ( ! m_hFileMapping )

  {

  MessageBox(_T("Creating of file mapping failed"));

  }

  枫叶文学网www.fywxw.com

  第9 章 多线程

  ·231·

  else

  {

  // 映shè文件

  m_pViewOfFile = MapViewOfFile(

  m_hFileMapping, // 句柄

  FILE_MAP_ALL_ACCESS, // 访问属xìng

  0,

  0,

  0); // 映shè所有文件

  if ( ! m_pViewOfFile )

  {

  MessageBox(_T("MapViewOfFile failed"));

  }

  }

  if ( dwError == ERROR_ALREADY_EXISTS )

  {

  // 已经有程序运行

  // 从内存文件中读取数据并且写入文本框

  if ( m_pViewOfFile )

  {

  //从内存文件中读取数据

  TCHAR s[dwMemoryFileSize];

  lstrcpy(s, (LPCTSTR) m_pViewOfFile);

  // 写入文本框

  m_bNotify = FALSE;

  m_input.SetWindowText(s);

  m_bNotify = TRUE;

  }

  }

  return TRUE;

  }

  枫叶文学网www.fywxw.com

  Visual C++ 6.0 程序设计从入门到精通

  ·232·

  (7)响应文本框输入

  响应文本框输入的消息EN_CHANGE,代码如下:

  void CIPCDemoDlg::OnChangeEditInput()

  {

  // TODO: Add your control notification handler code here

  if ( m_bNotify )

  {

  // 将字符写入映shè内存文件

  if ( m_pViewOfFile )

  {

  TCHAR s[dwMemoryFileSize];

  m_input.GetWindowText(s, dwMemoryFileSize);

  lstrcpy( (LPTSTR) m_pViewOfFile, s);

  // 给其他线程发消息, 文本框中的字符发生变化

  ::PostMessage(HWND_BROADCAST,

  WM_MyMessage,

  (WPARAM) m_hWnd,

  0);

  }

  }

  }

  (8)响应自定义消息

  响应自定义的消息WM_MyMessage,代码如下:

  LRESULT CIPCDemoDlg::OnMyMessage(WPARAM wParam, LPARAM lParam)

  {

  // 如果是线程自己发送的消息, 则不作响应

  if ( wParam == (WPARAM) m_hWnd )

  return 0;

  // 从内存映shè文件读取文本, 设置自己文本框的文本

  if ( m_pViewOfFile )

  {

  // 从内存映shè文件读取文本

  TCHAR s[dwMemoryFileSize];

  lstrcpy(s, (LPCTSTR) m_pViewOfFile);

  枫叶文学网www.fywxw.com

  第9 章 多线程

  ·233·

  // 将文本写入文本框

  m_bNotify = FALSE;

  m_input.SetWindowText(s);

  m_bNotify = TRUE;

  }

  return 0;

  }

  (9)释放资源

  改写对话框退出消息WM_DESTROY 的响应函数OnDestroy,释放资源,代码如下:

  void CIPCDemoDlg::OnDestroy()

  {

  CDialog::OnDestroy();

  // TODO: Add yourcomssage handler code here

  if ( m_hFileMapping )

  {

  if ( m_pViewOfFile )

  {

  UnmapViewOfFile(m_pViewOfFile); // 释放内存映shè视图

  }

  // 释放内存映shè资源

  CloseHandle(m_hFileMapping);

  }

  }

  (10)运行结果

  运行多个程序,改变文本框的内容,界面如图9-3 所示。

  图9-3 程序运行界面

  枫叶文学网www.fywxw.com

  Visual C++ 6.0 程序设计从入门到精通

  ·234·

  9.3.5 线程的同步

  在多线程程序设计中,经常会出现两个或多个线程使用一个公共变量,或者多个线程共

  享一些公共存储区的情况。凡是涉及到共享资源的情况都有可能会引起程序的错误。为了解

  决这些问题,Windows 提供了大量线程的同步方法,例如变量锁、临界区、信号量、事件对

  象、互斥对象等。

  1.互锁cāo作

  一个或两个变量的互锁cāo作是最简单的同步原语。Win32 提供了7 个具有线程安全xìng的

  原子cāo作,具体介绍如下。

  (1)InterlockedIncrcomnt

  函数InterlockedIncrcomnt 为指定的32 位变量加一,并且对结果进行检查。该函数不允

  许同一时间有大于一个的线程对变量进行访问。返回执行加一cāo作后的变量值。它的函数原

  型如下:

  LONG InterlockedIncrcomnt(

  LPLONG volatile lpAddend

  );

  函数中主要参数的意义如下。

  ? LpAddend:指向变量的指针。

  (2)InterlockedDecrcomnt

  函数InterlockedDecrcomnt 为指定的32 位变量减一,并且对结果进行检查。该函数不允

  许同一时间有大于一个的线程对变量进行访问。返回执行减一cāo作后的变量值。它的函数原

  型如下:

  LONG InterlockedDecrcomnt(

  LPLONG volatile lpAddend

  );

  函数中主要参数的意义如下。

  ? lpAddend:指向变量的指针。

  (3)InterlockedExchange

  函数InterlockedExchange 自动jiāo换一对变量值。该函数不允许同一时间有多于一个的线

  程对指定的变量进行访问。如果jiāo换指针值,则调用函数InterlockedExchangePointer。返回

  Target 指向的初值。函数InterlockedExchange 的函数原型如下:

  LONG InterlockedExchange(

  LPLONG volatile Target,

  LONG Value

  );

  函数中主要参数的意义如下。

  ? Target:要jiāo换的变量指针。

  ? Value:Target 指向变量的新值。

  枫叶文学网www.fywxw.com

  第9 章 多线程

  ·235·

  (4)InterlockedExchangeAdd

  函

  松语文学免费小说阅读_www.16sy.com