2. 程式人生 > >C++多線程同步技巧（二）--- 事件

C++多線程同步技巧（二）--- 事件

阿新 • • 發佈：2018-10-01
create include 解鎖 signed 選擇 參數 bre tdi 人工

簡介

Windows在線程同步方面提供了多種信號處理機制，其中一種便是使用 CreateEvent() 函數創建事件，然後使用信號控制同步。其中將事件變為有信號可使用 SetEvent() 函數，將事件信號復位（變為無信號）可使用 ResetEvent() 函數，信號可以配合 WaitForSingleObject() 函數進行控制，當有信號時，此函數便會放行；無信號時，此函數會將阻塞。

提示： CreateEvent() 函數的參數 bManualReset 的含義是信號是否由人工復位，如果選擇true，則信號必須手動采用ResetEvent() 函數進行復位操作，在這種情況下，可能會偶爾出現線程不同的情況，問題出在可能同時會有多個線程穿過 WaitForSingleObject()

函數，導致復位失效，所以在這種情況下，為確保萬無一失，我們一般會再添加一個限制條件，例如臨界區或互斥體；如果選擇的是false，則當一個信號經過 WaitForSingleObject() 函數的時候，函數會自動將事件信號復位。

代碼樣例

  • bManualReset參數為false
////////////////////////////////
//
// FileName : ThreadEventDemo.cpp
// Creator : PeterZheng
// Date : 2018/9/23 18:00
// Comment : The usage of "CreateEvent"
//
////////////////////////////////

#pragma once

#include <cstdio>
#include <iostream>
#include <cstdlib>
#include <windows.h>

using namespace std;

DWORD WINAPI func1(LPVOID lpParam);
DWORD WINAPI func2(LPVOID lpParam);

HANDLE hEvent = NULL;
unsigned int unCount = 0;

DWORD WINAPI func1(LPVOID lpParam)
{
    while (true)
    {
        WaitForSingleObject(hEvent, INFINITE);
        ResetEvent(hEvent);
        if (unCount < 100)
        {
            unCount++;
            Sleep(10);
            cout << "Count: " << unCount << endl;
            SetEvent(hEvent);
        }
        else
        {
            SetEvent(hEvent);
            break;
        }
    }
    return 0;
}

DWORD WINAPI func2(LPVOID lpParam)
{
    while (true)
    {
        WaitForSingleObject(hEvent, INFINITE);
        ResetEvent(hEvent); // 重置事件為無信號狀態
        if (unCount < 100)
        {
            unCount++;
            Sleep(10);
            cout << "Count: " << unCount << endl;
            SetEvent(hEvent); // 設置事件為有信號狀態
        }
        else
        {
            SetEvent(hEvent);
            break;
        }
    }
    return 0;
}

int main(void)
{
    HANDLE hThread[2] = { NULL };
    hEvent = CreateEvent(NULL, false, false, NULL); //創建一個匿名事件,當參數bManualReset設置為false時
    hThread[0] = CreateThread(NULL, 0, func1, NULL, 0, NULL);
    cout << "Thread-1 is RUNNING" << endl;
    hThread[1] = CreateThread(NULL, 0, func2, NULL, 0, NULL);
    cout << "Thread-2 is RUNNING" << endl;
    SetEvent(hEvent);
    WaitForMultipleObjects(2, hThread, true, INFINITE); //等待兩個線程運行結束
    CloseHandle(hThread[0]);
    CloseHandle(hThread[1]);
    CloseHandle(hEvent);
    system("pause");
    return 0;
}
  • bManualReset參數為true
////////////////////////////////
//
// FileName : ThreadEventDemo.cpp
// Creator : PeterZheng
// Date : 2018/9/23 18:00
// Comment : The usage of "CreateEvent"
//
////////////////////////////////

#pragma once

#include <cstdio>
#include <iostream>
#include <cstdlib>
#include <windows.h>

using namespace std;

DWORD WINAPI func1(LPVOID lpParam);
DWORD WINAPI func2(LPVOID lpParam);

HANDLE hEvent = NULL;
HANDLE hMutex = NULL;
unsigned int unCount = 0;

DWORD WINAPI func1(LPVOID lpParam)
{
    while (true)
    {
        WaitForSingleObject(hEvent, INFINITE);
        WaitForSingleObject(hMutex, INFINITE); //為互斥體上鎖
        ResetEvent(hEvent); // 重置事件為無信號狀態
        if (unCount < 100)
        {
            unCount++;
            Sleep(10);
            cout << "Count: " << unCount << endl;
            SetEvent(hEvent); // 設置事件為有信號狀態
            ReleaseMutex(hMutex); //互斥體解鎖
        }
        else
        {
            SetEvent(hEvent);
            ReleaseMutex(hMutex);
            break;
        }
    }
    return 0;
}

DWORD WINAPI func2(LPVOID lpParam)
{
    while (true)
    {
        WaitForSingleObject(hEvent, INFINITE);
        WaitForSingleObject(hMutex, INFINITE); //為互斥體上鎖
        ResetEvent(hEvent); // 重置事件為無信號狀態
        if (unCount < 100)
        {
            unCount++;
            Sleep(10);
            cout << "Count: " << unCount << endl;
            SetEvent(hEvent); // 設置事件為有信號狀態
            ReleaseMutex(hMutex);
        }
        else
        {
            SetEvent(hEvent);
            ReleaseMutex(hMutex);
            break;
        }
    }
    return 0;
}

int main(void)
{
    HANDLE hThread[2] = { NULL };
    hEvent = CreateEvent(NULL, true, false, NULL); //創建一個匿名事件,當參數bManualReset設置為true時
    hMutex = CreateMutex(NULL, false, NULL); //創建一個匿名互斥體
    hThread[0] = CreateThread(NULL, 0, func1, NULL, 0, NULL);
    cout << "Thread-1 is RUNNING" << endl;
    hThread[1] = CreateThread(NULL, 0, func2, NULL, 0, NULL);
    cout << "Thread-2 is RUNNING" << endl;
    SetEvent(hEvent); // 設置事件為有信號狀態
    WaitForMultipleObjects(2, hThread, true, INFINITE); //等待兩個線程運行結束
    CloseHandle(hThread[0]);
    CloseHandle(hThread[1]);
    CloseHandle(hEvent);
    CloseHandle(hMutex);
    system("pause");
    return 0;
}

C++多線程同步技巧（二）--- 事件

相關推薦

C++多線程同步技巧（二）--- 事件

create include 解鎖 signed 選擇 參數 bre tdi 人工 簡介 Windows在線程同步方面提供了多種信號處理機制，其中一種便是使用 CreateEvent() 函數創建事件，然後使用信號控制同步。其中將事件變為有信號可使用 SetEvent()

C++多線程同步技巧（一） --- 臨界區

定義 process i++ 線程 del 文件創建 結構 UNC pau 簡介 C++中關於多線程的內容對於構建工程來說是至關重要的，C++本身也對關於多線程的操作提供了很好的支持。本章筆者就來介紹一下C++有關於多線程的重要知識點---臨界區。 臨界區的作用 線程

C++多執行緒同步技巧（二） ---事件

簡介 Windows線上程控制方面提供了多種訊號處理機制，其中一種便是使用 CreateEvent() 函式建立事件，然後使用訊號控制執行緒執行。其中將事件變為有訊號可使用 SetEvent() 函式，將事件訊號復位（變為無訊號）可使用 ResetEvent(

多線程基礎知識（二）

必須 否則 closed form 自己 back play sender 重點 線程池 因為每次創建線程、銷毀線程都比較消耗 cpu 資源，因此可以通過線程池進行優化。線程池是一組已經創建好的線程，隨用隨取，用完了不是銷毀線程，然後放到線程池中，供其他人用。 用線程池之

Java多線程學習篇（二）synchronized

參考 .get name syn his col 靜態方法 runtest 作用範圍 synchronized 有二種修飾方法： 修飾一個方法 synchronized public void runTest{ /**/ } 修飾一個代碼塊 publi

Java 多線程詳解（三）------線程的同步

alt 來看 監聽 介紹 創建進程 java 多線程 system ima 關鍵字 Java 多線程詳解（一）------概念的引入：http://www.cnblogs.com/ysocean/p/6882988.html Java 多線程詳解（二）------如何創建進

c++多線程——鎖技巧

沒有機會 tail 錯誤 特性 每次 中間 urn 你會 get 【轉自】here 編寫程序不容易，編寫多線程的程序更不容易。相信編寫過多線程的程序都應該有這樣的一個痛苦過程，什麽樣的情況呢？朋友們應該看一下代碼就明白了， void data_process() {

java多線程快速入門（二十一）

第一次 () trace for import else spl 自己的 arr CountDownLatch（閉鎖）計數器 　　有一個任務A，它要等待其他4個任務執行完畢之後才執行，此時就可以利用CountDownLatch來實現這種功能 package com.cp

進程同步概念簡介 多線程上篇（四）

target 事件 hog 場景 相關 img 一個數 行操作 申請 進程同步概念 臨界資源 一旦有對資源的共享，就必然涉及競爭限制 比如盡管有兩個人去水井打水，但是水井卻只有一個；合理安排的話剛好錯開，但是如果安排不合理，那就會出現沖突，出現沖突怎麽辦？

進程同步經典示例 多線程上篇（五）

put 主程序 進程間互斥 結束 只需要 pla 並發執行 是什麽 消費者 同步回顧 進程同步控制有多種方式：算法、硬件、信號量、管程 這些方式可以認為就是同步的工具（方法、函數） 比如信號量機制中的wait(S) 和 signal(S) ，就相當於是兩個方法調用

netty源碼分析之揭開reactor線程的面紗（二）

研究 tle 一段 issue 一段時間 [] iter cts ova 如果你對netty的reactor線程不了解，建議先看下上一篇文章netty源碼分析之揭開reactor線程的面紗（一），這裏再把reactor中的三個步驟的圖貼一下reactor線程我們已經了解到n

多線程設計模式（一）

exceptio 很多 main 定義 網絡協議 name 停止 一個隊列 處理 DelayQueue的使用設計 我們談一下實際的場景吧。我們在開發中，有如下場景a) 關閉空閑連接。服務器中，有很多客戶端的連接，空閑一段時間之後需要關閉之。b) 緩存。緩存中的對象，超過了空

多線程：多線程設計模式（三）：Master-Worker模式

fonts strong stat bre not 多線程 too () 部分 Master-Worker模式是常用的並行模式之一，它的核心思想是，系統有兩個進程協作工作：Master進程，負責接收和分配任務；Worker進程，負責處理子任務。當Worker進程將子任務處理

Java多線程學習篇（三）Lock

參考 簡單 which sys lin int some call row Lock 是Java多線程的一個同步機制，用來控制線程對共享資源的訪問。線程在執行同步方法或者代碼塊之前必須先獲得一個鎖。 Lock 的 lock() 和 unlock() 方法; 　　lock()

Java多線程系列目錄（轉）

系列 ren semaphore epo all 概念 lin field 線程終止 轉載方便自己學習，轉自：Java多線程系列目錄(共43篇) http://www.cnblogs.com/skywang12345/p/java_threads_category.html

JUC——線程同步鎖（ReentrantLock）

spa his 進入 star zab serial 進行 zed util ReentrantLock簡介 ReentrantLock是一個可重復的互斥鎖，又被稱為獨占鎖，可重入的意思是：ReentrantLock鎖可以被單個線程多次獲取。但是在同一個時間點只能被一個線程

java多線程快速入門（三）

err out clas pri pub ride style 通過 () //通過實現Runnable接口實現多線程 package com.cppdy; //通過實現Runnable接口實現多線程 class MyThread1 implements Runnab

java多線程快速入門（六）

static code msg close play int vat one bsp 多線程應用實例（批量發送短信） 1、創建實體類 package com.cppdy; public class UserEntity { private int i

java多線程快速入門（七）

什麽是 mon span 一個 demo start end java多線 ack 什麽是守護線程 　　守護線程是為用戶線程服務的這麽一個線程，主線程結束，守護線程也結束 package com.cppdy; class MyThread3 extends Thread

多執行緒同步理解（二）——lock鎖方式

  上篇文章，已經提了同步鎖的synchronized的物件鎖和類鎖。這一節我決定研究lock鎖的實現方式。lock鎖可以做到執行緒同步，也就是在多執行緒裡面實現加鎖，同步。    一、同一個物件同步鎖的區域性lock。            為同一個物件呼叫同一個方法的時候