当前位置：首页 > news >正文

一步一步写线程之十六线程的安全退出之二例程

news 2025/7/9 4:10:16

一、说明

在一篇分析了多线程的安全退出的相关机制和方式，那么本篇就针对前一篇的相关的分析进行举例分析。因为有些方法实现的方法类似，可能就不一一重复列举了，相关的例程主要以在Linux上的运行为主。

二、实例

线程间的同步，其实理解清楚动作的原理并不麻烦，麻烦的在于如何和业务较好的契和起来。直白的说就是用得恰到好处。所以下面的分析的方法，只是告诉大家这是一类手段，如何能更好的运用，才看开发者具体的要求是什么。
1、等待方式

#include <atomic>
#include <condition_variable>
#include <iostream>
#include <mutex>
#include <signal.h>
#include <thread>
#include <unistd.h>std::atomic_bool quit = false;struct Data {int Display(int c) {std::cout << "Display value:" << c << std::endl;return c;}
};void threadWorkSleep(Data *d) {//模拟工作for (int c = 0; c < 10000; c++) {std::cout << "threadWorkSleep:call Data func:" << d->Display(c) << std::endl;}
}int main() {Data *pd = new Data;std::thread t = std::thread(threadWorkSleep, pd);t.detach();// firt:sleep thread safe quitsleep(1);return 0;
}

大家可以试着调整一下等待和模拟工作的时间，就可以发现具体的关系。实际的场景下，可能要求必须完成线程的工作才能退出。而如果等待时长不够，则线程就来不及完成相关的工作就退出了，那么，就没有实现业务的要求。等待的方式很粗暴，但也很简单。

2、轮询方式

#include <atomic>
#include <condition_variable>
#include <iostream>
#include <mutex>
#include <signal.h>
#include <thread>
#include <unistd.h>std::atomic_bool quit = false;struct Data {int Display(int c) {std::cout << "Display value:" << c << std::endl;return c;}
};void threadWorkPolling(Data *d) {for (int c = 0; c < 10000; c++) {std::cout << "threadWorkPolling:call Data func:" << d->Display(c) << std::endl;}quit = true;
}int main() {Data *pd = new Data;// sec:Pollingstd::thread tp = std::thread(threadWorkPolling, pd);while (!quit) {std::cout << "polling quit:" << quit << std::endl;}std::cout << "polling thread safe quit.quit is:" << quit << std::endl;std::cout << "master thread thread!" << std::endl;// or deatchif (tp.joinable()) {tp.join();}return 0;
}

轮询的方式其实就是不断反复的查看是否可以退出了，这样做虽然安全，但浪费时间。就和现实社会一样，本来一个人干得活还得安排一个人去没事转转。

3、消息方式

#include <atomic>
#include <condition_variable>
#include <iostream>
#include <mutex>
#include <signal.h>
#include <thread>
#include <unistd.h>std::atomic_bool quit = false;struct Data {int Display(int c) {std::cout << "Display value:" << c << std::endl;return c;}
};// third:msg or signal
static void sigHandler(int sigNo) {std::cout << "recv msg no is:" << sigNo << std::endl;if (sigNo == SIGUSR1) {quit = true;std::cout << "recv SIGUSR1" << std::endl;}
}
// third:msg or signal
void threadWorkMsg(Data *d) {for (int c = 0; c < 10000; c++) {std::cout << "threadWorkMsg:call Data func:" << d->Display(c) << std::endl;}int ret = raise(SIGUSR1);if (ret < 0) {std::cout << "SIGUSR1 msg send err!" << std::endl;}
}int main() {Data *pd = new Data;// msgsignal(SIGUSR1, sigHandler);std::thread ts = std::thread(threadWorkMsg, pd);ts.detach();while (!quit) {std::cout << "msg or signal quit:" << quit << std::endl;}std::cout << "polling thread safe quit.quit is:" << quit << std::endl;return 0;
}

这个信号的例程因为和其它程序共用的原因，把信号放到了主程序这样看起来也有点轮询的意思，其实如果把事件接收放到线程中反而更好体现这种情况。有兴趣可以试试。

4、事件方式

#include <atomic>
#include <condition_variable>
#include <iostream>
#include <mutex>
#include <signal.h>
#include <thread>
#include <unistd.h>std::atomic_bool quit = false;struct Data {int Display(int c) {std::cout << "Display value:" << c << std::endl;return c;}
};// fourth:event
std::condition_variable conv;
std::mutex mt;
bool signaled = false;
void threadWorkEvent(Data *d) {for (int c = 0; c < 100; c++) {std::cout << "threadWorkEvent:call Data func:" << d->Display(c) << std::endl;}signaled = true;std::cout << "threadWorkEvent,set notify_one!" << std::endl;conv.notify_one();
}int main() {Data *pd = new Data;// eventstd::thread te = std::thread(threadWorkEvent, pd);te.detach();std::unique_lock<std::mutex> lock(mt);while (!signaled) {std::cout << "thread start wait....!" << std::endl;conv.wait(lock);}std::cout << "thread recv notify_one and quit wait!" << std::endl;std::cout << "master thread thread!" << std::endl;return 0;
}