C++ 简单的任务队列详解
更新时间:2020年4月25日 17:33 点击:1700
任务队列是指能够实现任务在多线程间安全传递的先入先出的队列。
任务是指组合了数据和操作的对象,这里面定义为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++ 简单的任务队列详解就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持猪先飞。
相关文章
- php5.3或以上版本可以使用php管理crontab计划任务,下面我先来体验一下,有需要学习了解的朋友可进入参考。 1.使用php-crontab-manager管理计划任务 要求 PHP>=5.3...2016-11-25
- 这篇文章主要介绍了c++中system("pause")的作用和含义,非常不错,具有参考借鉴价值,需要的朋友参考下吧...2020-04-25
基于BootStrap Metronic开发框架经验小结【八】框架功能总体界面介绍
这篇文章主要介绍了基于BootStrap Metronic开发框架经验小结【八】框架功能总体界面介绍 的相关资料,需要的朋友可以参考下...2016-05-14- 这篇文章主要介绍了C# 16 进制字符串转 int的方法,非常不错,具有参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 队列的特性很简答,就是先进先出,一般利用数组来实现,本文就介绍了C#队列的简单使用,文中根据实例编码详细介绍的十分详尽,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2022-03-17
- 这篇文章主要介绍了SpringBoot集成Redis实现消息队列的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-10
InterlliJ IDEA2020新建java web项目找不到Static Web的解决
这篇文章主要介绍了InterlliJ IDEA2020新建java web项目找不到Static Web的解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-09-02- 这篇文章主要介绍了C#判断一个字符串是否是数字或者含有某个数字的方法,本文给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了C#类中static变量用法,实例分析了static变量使用技巧与相关注意事项,需要的朋友可以参考下...2020-06-25
- 这篇文章主要给大家介绍C# winform快捷键设置技巧,涉及到C winform快捷键相关知识,对C winform知识感兴趣的朋友可以参考下本篇文章...2020-06-25
- 最近项目不多忙,于是抽点时间巩固下切换窗口问题,感兴趣的朋友跟着小编一起学习吧...2020-06-25
- 这篇文章主要介绍了基于Ionic3实现选项卡切换并重新加载echarts,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-09-24
pytorch绘制并显示loss曲线和acc曲线,LeNet5识别图像准确率
今天小编就为大家分享一篇pytorch绘制并显示loss曲线和acc曲线,LeNet5识别图像准确率,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-05-02- 这篇文章主要为大家详细介绍了PC蓝牙通信C#代码实现,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2020-06-25
- 这篇文章主要介绍了C#实现带进度条的ListView 的相关资料,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了SpringMVC文件上传原理及实现过程解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-07-15
基于BootStrap Metronic开发框架经验小结【六】对话框及提示框的处理和优化
这篇文章主要介绍了基于BootStrap Metronic开发框架经验小结【六】对话框及提示框的处理和优化的相关知识,主要对比说明在Bootstrap开发中用到的这些技术要点,对此文感兴趣的朋友一起学习吧...2016-05-14- 这篇文章主要介绍了C#向线程中传递多个参数的解决方法(两种)的相关资料,非常不错,具有参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了c++优先队列(priority_queue)用法详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-04-25
C# MVC模式中应该怎样区分应用程序逻辑(Controller层)和业务逻辑(Model层)?
这篇文章主要介绍了C# MVC模式中应该怎样区分应用程序逻辑(Controller层)和业务逻辑(Model层)?,这也小编做.NET项目时经常思考和让人混乱的一个问题,这篇文章写的挺好,一下清晰了许多,需要的朋友可以参考下...2020-06-25