Windows線程漫談界麵線程和工作者線程

来源:http://www.cnblogs.com/roucheng/archive/2016/05/30/winxiancheng.html
-Advertisement-
Play Games

每個系統都有線程，而線程的最重要的作用就是並行處理，提高軟體的併發率。針對界面來說，還能提高界面的響應力。 線程分為界麵線程和工作者線程，界面實際就是一個線程畫出來的東西，這個線程維護一個“消息隊列”，“消息隊列”也是界麵線程和工作者線程的最大區別，這個詞應該進到你的腦子裡，根深蒂固的！ 如果在界面 ...


每個系統都有線程，而線程的最重要的作用就是並行處理，提高軟體的併發率。針對界面來說，還能提高界面的響應力。

 線程分為界麵線程和工作者線程，界面實際就是一個線程畫出來的東西，這個線程維護一個“消息隊列”，“消息隊列”也是界麵線程和工作者線程的最大區別，這個詞應該進到你的腦子裡，根深蒂固的！

如果在界麵線程的某個地方停住，這說明它處理不了視窗消息了，所以有時候我們就會看到整個界面無響應了。這種問題後面會提供一個叫　WaitForObjectEx　的函數來解決，我們後面再談。

線程首先就是它的創建，創建是用下麵這個函數：CreateThread;　具體的參數我不說了，自己查ＭＳＤＮ。其中的　Thread1　是線程函數。線程函數是一個全局函數，如下：

DWORD WINAPI Thread1(LPVOID lpParam)
{
  while(1)
 {
  OutputDebugString("11111");

  Sleep(10);
 }
 return 0;
}

// 下麵這一句是創建線程
CreateThread(NULL, 0, Thread1, 0, 0, NULL);

當然我們不能讓一個線程自生自滅，那樣有可能在你退出程式的時候出現一些莫名其妙的問題，或者丟失一些數據，或者給你彈一個崩潰的對話框等等。。。

所以我們就要對這個線程進行管理，首先就是讓它退出。

我們給它的while加上一個 BOOL 變數 g_bExitThread的判斷，這樣的話，線程函數就變成下麵這樣：

DWORD WINAPI Thread1(LPVOID lpParam)
{
  while(!g_bExitThread)
 {
  OutputDebugString("11111");

  Sleep(10);
 }
 return 0;
}

然後在需要它退出的時候把g_bExitThread設為TRUE，表示，喂，兄弟，你該退出了。

當然我們還要知道它是否成功退出了，因為線程句柄是一個內核對象，所以我們就要用到Windows的WaitForSingleObject來等待了。創建的時候和等待它退出的代碼就要改變了，多了一個 HANDLE g_hTrd的變數：

// 創建
g_bExitThread = FALSE;
g_hTrd = CreateThread(NULL, 0, Thread1, 0, 0, NULL);

// 等待線程結束
g_bExitThread = TRUE;

 if(g_hTrd != NULL)
 {
  DWORD dwRet = WaitForSingleObject(g_hTrd, 5000);
  if(dwRet == WAIT_OBJECT_0)
  {
   AfxMessageBox("Thread exit success!");
  }
  else
  {
   DWORD dwRet = 0;
   GetExitCodeThread(g_hTrd, &dwRet);
   TerminateThread(g_hTrd, dwRet);
   AfxMessageBox("Thread exit, but not all ok!");
  }
  CloseHandle(g_hTrd);
  g_hTrd = NULL;
 }

上面說了在界麵線程里等待別的線程結束，也就是使用 WaitForSingleObject 的時候會阻塞整個視窗消息的處理，所以我們如果在界麵線程里要等待別的內核對象時，我們要採用這種“等一下，處理一下界面消息”的方法。我已經寫好了一個 WaitForObjectEx 的函數，如下：

// 此函數只能用於界麵線程
static DWORD WaitForObjectEx( HANDLE hHandle, DWORD dwMilliseconds )
{
 BOOL bRet;
 MSG msg;
 INT iWaitRet;
 int nTimeOut = 0;
 while( (bRet = ::GetMessage( &msg, NULL, 0, 0 )) != 0)
 { 
  if(nTimeOut++ * 20 >= dwMilliseconds)
   break;

  iWaitRet = WaitForSingleObject(hHandle, 20);
  if(iWaitRet != WAIT_TIMEOUT)
  {
   break;
  }
  if (bRet == -1)
  {
   break;
  }
  else
  {
   ::TranslateMessage(&msg); 
   ::DispatchMessage(&msg); 
  }
 }

 return iWaitRet;
}

很多時候，我們不想把線程作為一個全局函數來使用，所以這個時候我們把線程作為一個類的靜態成員對象來寫。當然也不能少了剛纔的兩個變數：退出標誌和線程句柄。（設這個類是CTestThreadDlg）

// H 文件 
BOOL m_bExitThread;
 HANDLE m_hTrd;
 static DWORD WINAPI Thread1(LPVOID lpParam);

// CPP文件，創建的時候把 this 指針傳進去，因為類靜態成員函數不能訪問類的非靜態成員，沒有this指針
//（C++的知識點）
 m_bExitThread = FALSE;
 m_hTrd = CreateThread(NULL, 0, Thread1, this, 0, NULL);

線程函數變成了：

 DWORD WINAPI CTestThreadDlg::Thread1(LPVOID lpParam)
 {
  CTestThreadDlg *pDlg = (CTestThreadDlg*)lpParam;
  while(!pDlg->m_bExitThread)
  {
   OutputDebugString("11111");
  
   Sleep(10);
  }
  return 0;
 }

當有幾個線程一起跑的時候，我們就要註意線程的同步問題了，線程的同步一般來說，是在多個線程共用了資源的時候。比如兩個線程都用到了同一個VECTOR，都對VECTOR進行插入操作，不幸的是，VECTOR不是線程安全的，這個時候程式就會崩潰，所以我們就要對VECTOR這個資源做同步，同步的意思是“我訪問的時候，你等待”。程式大致如下：

DWORD WINAPI CTestThreadDlg::Thread1(LPVOID lpParam)
 {
  CTestThreadDlg *pDlg = (CTestThreadDlg*)lpParam;
  while(!pDlg->m_bExitThread)
  {
   OutputDebugString("11111");
 
   pDlg->m_csForVec.Lock();
   pDlg->m_vecTest.push_back("111");
   pDlg->m_csForVec.Unlock();
 
   Sleep(10);
  }
  return 0;
 }

DWORD WINAPI CTestThreadDlg::Thread2(LPVOID lpParam)
{
 CTestThreadDlg *pDlg = (CTestThreadDlg*)lpParam;
 while(!pDlg->m_bExitThread2)
 {
  OutputDebugString("222");

  pDlg->m_csForVec.Lock();
  pDlg->m_vecTest.push_back("222");
  pDlg->m_csForVec.Unlock(); 

  Sleep(10);
 }
 return 0;
}

m_csForVec 是一個CCriticalSection變數，這個同步對象和其他的同步變數（事件、信號量、互斥區等）有一些不一樣，例如只能在同一個進程的線程間訪問、在操作系統的用戶態訪問，其他的必須進入核心態。所以這樣導致了這種關鍵區的核心對象的速度要比其他的快100倍左右。。。

上面已經說了線程的創建、管理（退出線程、等待線程）、同步等，那我們發現了什麼共性呢？作為一個程式員，我們要很敏感的發現這些代碼上的共性，這是我們設計代碼的主要前提。

首先我們發現上面的線程都有兩個變數： 
BOOL m_bExitThread;  // 讓線程退出的標誌
 HANDLE m_hTrd;  // 線程句柄

另外我們WaitForSingleObject 的時候不能無限等待，所以要多一個 DWORD m_dwWaitTimeOut;

由於我想把線程啟動和結束封裝起來，所以我設計了這幾個介面：

 BOOL Start(LPVOID lpParam);  //  啟動線程，線程所需要的參數從這裡傳進
 BOOL End(); // 結束線程
 virtual void Run(); // 重寫Run函數 hovertree.com

所以整個的線程封裝成以下的類：

// MyThread.h

#ifndef MY_THREAD_H
#define MY_THREAD_H

class CMyThread
{
public:
 CMyThread();
 virtual ~CMyThread();

 BOOL Start(LPVOID lpParam);
 BOOL End();
 virtual void Run();

protected:
 static DWORD WINAPI Thread(LPVOID lpParam);
 void RunOnceEnd();

 DWORD m_dwWaitTimeOut;
 BOOL m_bExitThread;
 HANDLE m_hTrd;
 LPVOID m_lpParam;
};

#endif

// MyThread.Cpp

#include "stdafx.h"
#include "MyThread.h"
/////////////////////////////////////////////////////////////////////////////
// CMyThread
CMyThread::CMyThread()
{
 m_bExitThread = FALSE;
 m_hTrd = NULL;
 m_dwWaitTimeOut = 5000;
}

CMyThread::~CMyThread()
{

}

BOOL CMyThread::Start(LPVOID lpParam)
{
 m_lpParam = lpParam;
 m_bExitThread = FALSE;
 m_hTrd = CreateThread(NULL, 0, Thread, this, 0, NULL);

 return TRUE;
}

BOOL CMyThread::End()
{
 m_bExitThread = TRUE;

 if(m_hTrd != NULL)
 {
  DWORD dwRet = WaitForSingleObject(m_hTrd, m_dwWaitTimeOut);
  if(dwRet == WAIT_OBJECT_0)
  {
   AfxMessageBox("Thread exit success!");
  }
  else
  {
   DWORD dwRet = 0;
   GetExitCodeThread(m_hTrd, &dwRet);
   TerminateThread(m_hTrd, dwRet);
   AfxMessageBox("Thread fucking exit!");
  }

  CloseHandle(m_hTrd);
  m_hTrd = NULL;
 }
 
 return TRUE;
}

DWORD WINAPI CMyThread::Thread(LPVOID lpParam)
{
 CMyThread *pTrd = (CMyThread *)lpParam;
 
 while(!pTrd->m_bExitThread)
 {
  pTrd->Run();
 }

 return 0;
}

void CMyThread::RunOnceEnd()
{
 m_bExitThread = TRUE;
 CloseHandle(m_hTrd);
 m_hTrd = NULL;
}

void CMyThread::Run()
{
}

我們需要寫我們自己的線程的時候就重載一下這個Run函數

// 派生出一個類 何問起
class CMyThread1 : public CMyThread
{
public:
 virtual void Run();
};

// 改寫Run函數
void CMyThread1::Run()
{
 CTestThreadDlg *pDlg = (CTestThreadDlg *)m_lpParam;

 OutputDebugString("222");
 
 pDlg->m_csForVec.Lock();
 pDlg->m_vecTest.push_back("222");
 pDlg->m_csForVec.Unlock(); 
 
 Sleep(10);

 // 如果此線程只想運行一次，加上下麵這句
 RunOnceEnd();
}

然後我們之前的兩個線程的使用就變成了下麵的形式：

CMyThread1 g_t1, g_t2, g_t3;
void CTestThreadDlg::OnButton3() 
{
 g_t1.Start(this);
 g_t2.Start(this);
 g_t3.Start(this); 
}

void CTestThreadDlg::OnButton4() 
{
 g_t1.End();
 g_t2.End();
 g_t3.End();  
}

只需要以下幾步：
1、派生自己的線程類
2、重載Run函數
3、調用Start啟動線程
4、調用End結束線程

當然這種封裝方式是我自己喜歡的，封裝的目的是方便使用，隱藏細節，諸位看官也可以根據自己的喜好，封裝線程的使用方法，如果能在此公開一下你的成果，讓我和大家都學習一下你的設計手法，那就真是very good and 3q了！

http://www.cnblogs.com/roucheng/


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • linux埠號與PID的互相查詢
    最近用linux在玩Tomcat，啟動的時候總是會報錯（8080/8009/8005） 於是整理了一下網上零亂的查看PID和埠的命令，以備記錄。 1.由埠號查詢PID號 首先myeclipse報錯的時候會提示：“8009埠被占用”，那麼你不得不依據此埠去查看該埠下運行的哪些進程 使用命令來 ...
  • Mac OS 的一點歷史: Mac OS, Mac OSX 與Darwin
    作為收購 NeXT 公司的結果,蘋果公司獲得了 NeXTSTEP 架構中的 Mach 和 Objective-C 等設計。儘管 NeXTSTEP 本身已經不再發展了,但是其中的組件在 OS X 中獲得了新生。事實上,可以將 OS X 看成是 Mac OS Classic 和NeXTSTEP 的融合, ...
  • /etc/rc.d啟動目錄詳解
    操作系統：CentOS6.6_32位 控制腳本目錄/etc/rc.d，該目錄下存在各個運行級別的腳本文件，執行ls /etc/rc.d，顯示結果為：init.d rc rc0.d rc1.d rc2.d rc3.d rc4.d rc5.d rc6.d rc.local rc.sysinit。 /et ...
  • s5pv210學習之一步步點亮LED總結
    當我們想操控一個硬體的時候，我們有必要先去瞭解這個硬體的一些物理特性，比如如何點亮LED，那麼我們首先就得瞭解LED的一些特性，如下： LED本身有兩個接線點，一個是LED的負極，一個是LED的正極。LED這個硬體本身存在的作用就是亮或者不亮，而我們想要LED亮或者不亮，那就可以通過對LED的正負極 ...
  • Ubuntu配置Samba文件共用伺服器
    Samba是在Linux和UNIX系統上實現SMB協議的一個免費軟體，由伺服器及客戶端程式構成。SMB（Server Messages Block，信息服務塊）是一種在區域網上共用文件和印表機的一種通信協議，它為區域網內的不同電腦之間提供文件及印表機等資源的共用服務。 環境：Win7_64位+VM ...
  • Linux下的C編程實戰
    Linux下的C編程實戰（一） ――開發平臺搭建 1.引言 Linux操作系統在伺服器領域的應用和普及已經有較長的歷史，這源於它的開源特點以及其超越Windows的安全性和穩定性。而近年來， Linux操作系統在嵌入式系統領域的延伸也可謂是如日中天，許多版本的嵌入式Linux系統被開發出來，如ucL ...
  • makefile變數賦值
    在定義變數的值時，我們可以使用其它變數來構造變數的值，在Makefile中有兩種方式來在用變數定義變數的值。先看第一種方式，也就是簡單的使用“=”號，在“=”左側是變數，右側是變數的值，右側變數的值可以定義在文件的任何一處，也就是說，右側中的變數不一定非要是已定義好的值，其也可以使用後面定義的值。如 ...
  • linux學習筆記2-linux的基本命令
    第一篇博客：linux學習筆記1-ubuntu的安裝與基本設置 之中，已經介紹瞭如何安裝linux操作系統，以及一些基本的設置修改。 本篇博客主要介紹linux中的一些基本的控制台命令 ＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝ 連接遠程機器 以指定 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類