C++ 简单的任务队列详解_C 语言

任务队列是指能够实现任务在多线程间安全传递的先入先出的队列。

任务是指组合了数据和操作的对象,这里面定义为CTask类的对象。

任务的实现:

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();
};

队列的实现:

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);

  //等待线程结束
  if (thread1.joinable())
  {
    thread1.join();
  }
  if (thread2.joinable())
  {
    thread2.join();
  }

  system("pause");
  return 0;
}

以上这篇C++ 简单的任务队列详解就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。

以上是小编为您精心准备的的内容,在的博客、问答、公众号、人物、课程等栏目也有的相关内容,欢迎继续使用右上角搜索按钮进行搜索c
任务队列
c语言队列简单举例、java mq消息队列详解、磁盘队列长度详解、java 队列详解、消息队列详解,以便于您获取更多的相关知识。

时间: 2024-11-09 01:00:04

C++ 简单的任务队列详解_C 语言的相关文章

C语言 经典题目螺旋矩阵 实例详解_C 语言

C语言 经典题目螺旋矩阵 //N阶螺旋矩阵 #include <stdio.h> #include <stdlib.h> int main() { int N,i,j,n,num=1; int a[10][10]={0}; printf("输入你要输出的几阶中断:"); scanf("%d",&N); for(n=0;n<=N/2;n++) { for(j=n;j<=N-n-1;j++) a[n][j]=num++; fo

C++编程中的格式化输出详解_C 语言

在输出数据时,为简便起见,往往不指定输出的格式,由系统根据数据的类型采取默认的格式,但有时希望数据按指定的格式输出,如要求以十六进制或八进制形式输出一个 整数,对输出的小数只保留两位小数等.有两种方法可以达到此目的.一种是使用控制符的方法:第2种是使用流对象的有关成员函数.分别叙述如下. 使用控制符控制输出格式 控制格式的使用方法这里不再赘述,仅举例说明 [例] 用控制符控制输出格式. #include <iostream> #include <iomanip>//不要忘记包含此头

C++ Vector用法详解_C 语言

vector是C++标准模版库(STL,Standard Template Library)中的部分内容.之所以认为是一个容器,是因为它能够像容器一样存放各种类型的对象,简单的说:vector是一个能够存放任意类型的动态数组,能够增加和压缩数据. 使用vector容器之前必须加上<vector>头文件:#include<vector>; vector属于std命名域的内容,因此需要通过命名限定:using std::vector;也可以直接使用全局的命名空间方式:using nam

C++如何实现广义表详解_C 语言

以下给出几种简单的广义表模型:   由上图我们可以看到,广义表的节点类型无非head.value.sub三种,这里设置枚举类型,利用枚举变量来记录每个节点的类型: enum Type { HEAD, //头节点 VALUE, //值节点 SUB, //子表节点 }; 每个节点都有自己的类型以及next指针,除此之外,如果该节点是VALUE类型还要分配空间存储该节点的有效值:但是若该节点是SUB类型,就需定义一个指针指向子表的头. 这里我们可以用联合来解决这个问题. (联合(或共同体)是一种不同数

C语言实现大整数加减运算详解_C 语言

前言     我们知道,在数学中,数值的大小是没有上限的,但是在计算机中,由于字长的限制,计算机所能表示的范围是有限的,当我们对比较小的数进行运算时,如:1234+5678,这样的数值并没有超出计算机的表示范围,所以可以运算.但是当我们在实际的应用中进行大量的数据处理时,会发现参与运算的数往往超过计算机的基本数据类型的表示范围,比如说,在天文学上,如果一个星球距离我们为100万光年,那么我们将其化简为公里,或者是米的时候,我们会发现这是一个很大的数.这样计算机将无法对其进行直接计算.     可

Linux中使用VS Code编译调试C++项目详解_C 语言

前言 关于VS Code在Linux下的安装这里就不提了,不管是CentOS还是Ubuntu,如果不懂且搜问题足够的情况下,你会解决的. 一.前置知识--gcc/g++的编译链接过程 在Windows下,如果你用Visual Studio进行开发,C/C++的编译器一般采用微软提供的MSBuild:在Linux下C/C++的编译器大多采用gcc/g++.既然要在Linux下进行C++开发,很有必要了解一下g++编译器的一些基本知识. 假设我现在有一个最简单的C++文件: #include <io

C++中auto_ptr智能指针的用法详解_C 语言

智能指针(auto_ptr) 这个名字听起来很酷是不是?其实auto_ptr 只是C++标准库提供的一个类模板,它与传统的new/delete控制内存相比有一定优势,但也有其局限.本文总结的8个问题足以涵盖auto_ptr的大部分内容. auto_ptr是什么? auto_ptr 是C++标准库提供的类模板,auto_ptr对象通过初始化指向由new创建的动态内存,它是这块内存的拥有者,一块内存不能同时被分给两个拥有者.当auto_ptr对象生命周期结束时,其析构函数会将auto_ptr对象拥有

数据结构之伸展树详解_C 语言

1. 概述 二叉查找树(Binary Search Tree,也叫二叉排序树,即Binary Sort Tree)能够支持多种动态集合操作,它可以用来表示有序集合.建立索引等,因而在实际应用中,二叉排序树是一种非常重要的数据结构. 从算法复杂度角度考虑,我们知道,作用于二叉查找树上的基本操作(如查找,插入等)的时间复杂度与树的高度成正比.对一个含n个节点的完全二叉树,这些操作的最坏情况运行时间为O(log n).但如果因为频繁的删除和插入操作,导致树退化成一个n个节点的线性链(此时即为一个单链表

C++ 中try finally关键字详解_C 语言

try-finally语句是Microsoft对C和C++语言的扩展,它能使32位的目标程序在异常出现时,有效保证一些资源能够被及时清除,这些资源的清除任务可以包括例如内存的释放,文件的关闭,文件句柄的释放等等.try-finally语句特别适合这样的情况下使用,例如一个例程(函数)中,有几个地方需要检测一个错误,并且在错误出现时,函数可能提前返回. #include <windows.h> #include <stdio.h> try-finally语句的语法与try-excep