本篇内容主要讲解“C++11中std::thread线程怎么实现暂停功能”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“C++11中std::thread线程怎么实现暂停功能”吧!
我们基于C++11中与平台无关的线程类std::thread，封装Thread类，并提供start()、stop()、pause()、resume()线程控制方法。
为了让线程在暂停期间，处于休眠，不消耗CPU，我们使用C++11提供的锁和条件变量来实现。
std::mutex
std::condition_variable
Thread.h
计算
安全
数据库
网络和加速
企业服务
#ifndef THREAD_H
#define THREAD_H
#include <thread>
#include <atomic>
#include <mutex>
#include <condition_variable>
class Thread
{
public:
Thread();
virtual ~Thread();
enum State
{
Stoped, ///<停止状态，包括从未启动过和启动后被停止
Running, ///<运行状态
Paused ///<暂停状态
};
State state() const;
void start();
void stop();
void pause();
void resume();
protected:
virtual void process() = 0;
private:
void run();
private:
std::thread* _thread;
std::mutex _mutex;
std::condition_variable _condition;
std::atomic_bool _pauseFlag; ///<暂停标识
std::atomic_bool _stopFlag; ///<停止标识
State _state;
};
#endif // THREAD_HThread.cpp
#include "Thread.h"
#include <iostream>
using namespace std;
Thread::Thread()
: _thread(nullptr),
_pauseFlag(false),
_stopFlag(false),
_state(Stoped)
{
}
Thread::~Thread()
{
stop();
}
Thread::State Thread::state() const
{
return _state;
}
void Thread::start()
{
if (_thread == nullptr)
{
_thread = new thread(&Thread::run, this);
_pauseFlag = false;
_stopFlag = false;
_state = Running;
}
}
void Thread::stop()
{
if (_thread != nullptr)
{
_pauseFlag = false;
_stopFlag = true;
_condition.notify_all(); // Notify one waiting thread, if there is one.
_thread->join(); // wait for thread finished
delete _thread;
_thread = nullptr;
_state = Stoped;
}
}
void Thread::pause()
{
if (_thread != nullptr)
{
_pauseFlag = true;
_state = Paused;
}
}
void Thread::resume()
{
if (_thread != nullptr)
{
_pauseFlag = false;
_condition.notify_all();
_state = Running;
}
}
void Thread::run()
{
cout << "enter thread:" << this_thread::get_id() << endl;
while (!_stopFlag)
{
process();
if (_pauseFlag)
{
unique_lock<mutex> locker(_mutex);
while (_pauseFlag)
{
_condition.wait(locker); // Unlock _mutex and wait to be notified
}
locker.unlock();
}
}
_pauseFlag = false;
_stopFlag = false;
cout << "exit thread:" << this_thread::get_id() << endl;
}main.cpp
#include <QCoreApplication>
#include <iostream>
#include "Thread.h"
using namespace std;
void mySleep(int s)
{
std::this_thread::sleep_for(std::chrono::duration<double>(s));
}
class MyThread : public Thread
{
protected:
virtual void process() override
{
cout << "do my something" << endl;
mySleep(1);
}
};
int main(int argc, char *argv[])
{
QCoreApplication a(argc, argv);
MyThread thread;
cout << "start thread" << endl;
thread.start();
cout << "thread state:" << thread.state() << endl;
mySleep(3);
cout << "pause thread" << endl;
thread.pause();
cout << "thread state:" << thread.state() << endl;
mySleep(3);
cout << "resume thread" << endl;
thread.resume();
cout << "thread state:" << thread.state() << endl;
mySleep(3);
cout << "stop thread" << endl;
thread.stop();
cout << "thread state:" << thread.state() << endl;
mySleep(3);
return a.exec();
}运行结果：
到此，相信大家对“C++11中std::thread线程怎么实现暂停功能”有了更深的了解，不妨来实际操作一番吧！这里是亿速云网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://blog.csdn.net/zyhse/article/details/108751889
