C++ 簡單的任務隊列詳解
更新時間：2016年12月18日 12:29:27 投稿：jingxian
下面小編就為大家?guī)硪黄狢++ 簡單的任務隊列詳解。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
任務隊列是指能夠?qū)崿F(xiàn)任務在多線程間安全傳遞的先入先出的隊列。
任務是指組合了數(shù)據(jù)和操作的對象，這里面定義為CTask類的對象。
任務的實現(xiàn)：
Task.cpp
#include "stdafx.h"
#include "Task.h"
#include <iostream>
using namespace std;
CTask::CTask(int* nCount)
{
m_nCount = nCount;
}
CTask::~CTask()
{
}
void CTask::DoWork()
{
(*m_nCount)++;
cout << "Count = " << *m_nCount << endl;
}
Task.h
#pragma once
class CTask
{
int* m_nCount;
public:
CTask(int* nCount);
~CTask();
void DoWork();
};
隊列的實現(xiàn)：
TaskQueue.cpp
#include "stdafx.h"
#include "TaskQueue.h"
CTaskQueue::CTaskQueue()
{
}
CTaskQueue::~CTaskQueue()
{
}
//工作線程
void CTaskQueue::WorkThread()
{
while (m_bIsStart)
{
if (!m_taskQueue.empty())
{
CTask* it = m_taskQueue.front();
it->DoWork();
m_taskQueue.pop();
delete it;
}
}
}
//向任務隊列添加任務
bool CTaskQueue::Push(CTask* task)
{
if (task == nullptr)
{
return false;
}
m_mutex.lock();
m_taskQueue.push(task);
m_mutex.unlock();
return true;
}
//從任務隊列獲取任務
CTask* CTaskQueue::Pop()
{
CTask* it = nullptr;
m_mutex.lock();
if (!m_taskQueue.empty())
{
it = m_taskQueue.front();
m_taskQueue.pop();
}
m_mutex.unlock();
return it;
}
bool CTaskQueue::Start()
{
if (m_bIsStart)
{
return false;
}
m_bIsStart = true;
m_thread = std::thread(&CTaskQueue::WorkThread, this);
return true;
}
void CTaskQueue::Stop()
{
m_bIsStart = false;
m_thread.join();
}
TaskQueue.h
#pragma once
#include "Task.h"
#include <queue>
#include <mutex>
#include <thread>
class CTaskQueue
{
public:
CTaskQueue();
~CTaskQueue();
private:
std::queue<CTask*> m_taskQueue; //任務隊列
std::thread m_thread;
std::mutex m_mutex;
bool m_bIsStart; //線程是否開啟
public:
//工作線程
void WorkThread();
//向任務隊列添加任務
bool Push(CTask* task);
//從任務隊列獲取任務
CTask* Pop();
//開啟線程
bool Start();
//終止線程
void Stop();
};
測試demo：
// TaskQueue.cpp : 定義控制臺應用程序的入口點。
//
#include "stdafx.h"
#include "TaskQueue.h"
#include "Task.h"
void MyWorkTask1(CTaskQueue* pTaskQueue, int* nCount)
{
for (size_t i = 0; i < 20; i++)
{
CTask* task = new CTask(nCount);
pTaskQueue->Push(task);
}
}
void MyWorkTask2(CTaskQueue* pTaskQueue, int* nCount)
{
for (size_t i = 0; i < 20; i++)
{
CTask* task = new CTask(nCount);
pTaskQueue->Push(task);
}
}
int _tmain(int argc, _TCHAR* argv[])
{
CTaskQueue* pTaskQueue = new CTaskQueue();
pTaskQueue->Start();
int* nCount = new int(0);
std::thread thread1(&MyWorkTask1, pTaskQueue, nCount);
std::thread thread2(&MyWorkTask2, pTaskQueue, nCount);
//等待線程結(jié)束
if (thread1.joinable())
{
thread1.join();
}
if (thread2.joinable())
{
thread2.join();
}
system("pause");
return 0;
}
以上這篇C++ 簡單的任務隊列詳解就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持腳本之家。
您可能感興趣的文章:
相關文章
這篇文章主要為大家詳細介紹了基于C++寫一個推箱子小游戲,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2023-09-09
本篇文章是對用C++實現(xiàn)單向循環(huán)鏈表的解決方法進行了詳細的分析介紹，需要的朋友參考下2013-05-05
這篇文章主要介紹了詳解C語言-二級指針三種內(nèi)存模型的相關知識，文中代碼非常詳細，供大家參考和學習，感興趣的朋友可以了解下2020-06-06
這篇文章主要為大家詳細介紹了C語言的文件操作，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2022-03-03
這篇文章主要為大家介紹了C語言算法積累加tag的循環(huán)隊列的解題思路，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-06-06
這篇文章主要介紹了C++生成隨機數(shù)的實現(xiàn)代碼，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-04-04
這篇文章主要給大家介紹了關于Qt學習教程之對話框消失動畫效果的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2018-07-07
這篇文章主要為大家詳細介紹了C++設計模式之代理模式的相關資料，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-03-03
這篇文章主要為大家詳細介紹了C語言實現(xiàn)學生考勤系統(tǒng)，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-03-03
Matlab實現(xiàn)統(tǒng)計集合中各元素出現(xiàn)次數(shù)的示例代碼
統(tǒng)計數(shù)組中各個元素數(shù)量是一個很常用的功能，本文主要為大家介紹了如何利用Matlab優(yōu)雅的統(tǒng)計集合中各元素出現(xiàn)的次數(shù)，感興趣的可以了解一下2022-05-05