C++ 簡單的任務(wù)隊(duì)列詳解

來源：本站原創(chuàng)|時間：2020-01-10|欄目：C語言|點(diǎn)擊：次

任務(wù)隊(duì)列是指能夠?qū)崿F(xiàn)任務(wù)在多線程間安全傳遞的先入先出的隊(duì)列。

任務(wù)是指組合了數(shù)據(jù)和操作的對象，這里面定義為CTask類的對象。

任務(wù)的實(shí)現(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();
};

隊(duì)列的實(shí)現(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;
    }
  }
}

//向任務(wù)隊(duì)列添加任務(wù)
bool CTaskQueue::Push(CTask* task)
{
  if (task == nullptr)
  {
    return false;
  }

  m_mutex.lock();
  m_taskQueue.push(task);
  m_mutex.unlock();

  return true;
}
//從任務(wù)隊(duì)列獲取任務(wù)
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; //任務(wù)隊(duì)列
  std::thread m_thread;
  std::mutex m_mutex;
  bool m_bIsStart;  //線程是否開啟

public:
  //工作線程
  void WorkThread(); 

  //向任務(wù)隊(duì)列添加任務(wù)
  bool Push(CTask* task);
  //從任務(wù)隊(duì)列獲取任務(wù)
  CTask* Pop();

  //開啟線程
  bool Start();
  //終止線程
  void Stop();
};

測試demo：

// TaskQueue.cpp : 定義控制臺應(yīng)用程序的入口點(diǎn)。
//

#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++ 簡單的任務(wù)隊(duì)列詳解就是小編分享給大家的全部內(nèi)容了，希望能給大家一個參考，也希望大家多多支持我們。

上一篇：C++中的多態(tài)與虛函數(shù)的內(nèi)部實(shí)現(xiàn)方法

欄目：C語言

下一篇：C語言實(shí)現(xiàn)返回字符串函數(shù)的四種方法

本文標(biāo)題：C++ 簡單的任務(wù)隊(duì)列詳解

本文地址：http://mengdiqiu.com.cn/a1/Cyuyan/1927.html

更多C語言

欧美大屁股bbbbxxxx,狼人大香伊蕉国产www亚洲,男ji大巴进入女人的视频小说,男人把ji大巴放进女人免费视频,免费情侣作爱视频

C語言

C++ 簡單的任務(wù)隊(duì)列詳解

您可能感興趣的文章

閱讀排行

本欄相關(guān)

隨機(jī)閱讀