您好,登錄后才能下訂單哦!
在 Linux 中,使用 C++ 實現線程的優雅退出可以通過以下方法:
條件變量可以用于線程間的同步。當一個線程需要通知其他線程退出時,可以使用條件變量。這里是一個簡單的例子:
#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <vector>
std::mutex mtx;
std::condition_variable cv;
bool exit_flag = false;
void worker() {
std::unique_lock<std::mutex> lock(mtx);
while (!exit_flag) {
// 執行任務
std::cout << "Working...\n";
// 等待一段時間
cv.wait_for(lock, std::chrono::seconds(1));
}
}
int main() {
std::vector<std::thread> threads;
for (int i = 0; i < 5; ++i) {
threads.emplace_back(worker);
}
std::this_thread::sleep_for(std::chrono::seconds(3));
{
std::lock_guard<std::mutex> lock(mtx);
exit_flag = true;
}
cv.notify_all();
for (auto& t : threads) {
t.join();
}
return 0;
}
原子操作可以確保在多線程環境下對共享數據的操作是線程安全的。這里是一個簡單的例子:
#include <iostream>
#include <thread>
#include <atomic>
#include <vector>
std::atomic<bool> exit_flag(false);
void worker() {
while (!exit_flag) {
// 執行任務
std::cout << "Working...\n";
// 等待一段時間
std::this_thread::sleep_for(std::chrono::seconds(1));
}
}
int main() {
std::vector<std::thread> threads;
for (int i = 0; i < 5; ++i) {
threads.emplace_back(worker);
}
std::this_thread::sleep_for(std::chrono::seconds(3));
exit_flag = true;
for (auto& t : threads) {
t.join();
}
return 0;
}
在這兩個例子中,我們創建了一個名為 exit_flag
的共享變量,用于通知線程退出。當主線程需要通知所有工作線程退出時,它將 exit_flag
設置為 true
。工作線程會檢查 exit_flag
的值,如果為 true
,則退出循環并結束線程。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。