std :: atomic_flag停止多個線程

Question

我試圖停止多個工作線程使用std::atomic_flag。從Issue using std::atomic_flag with worker thread開始了以下工作：

#include <iostream> 
#include <atomic> 
#include <chrono> 
#include <thread> 

std::atomic_flag continueFlag; 
std::thread t; 

void work() 
{ 
    while (continueFlag.test_and_set(std::memory_order_relaxed)) { 
     std::cout << "work "; 
     std::this_thread::sleep_for(std::chrono::milliseconds(10)); 
    } 
} 

void start() 
{ 
    continueFlag.test_and_set(std::memory_order_relaxed); 
    t = std::thread(&work); 
} 

void stop() 
{ 
    continueFlag.clear(std::memory_order_relaxed); 
    t.join(); 
} 

int main() 
{ 
    std::cout << "Start" << std::endl; 
    start(); 
    std::this_thread::sleep_for(std::chrono::milliseconds(200)); 
    std::cout << "Stop" << std::endl; 
    stop(); 
    std::cout << "Stopped." << std::endl; 

    return 0; 
} 

試圖改寫成多個工作線程：

#include <iostream> 
#include <atomic> 
#include <chrono> 
#include <thread> 
#include <vector> 
#include <memory> 

struct thread_data { 
    std::atomic_flag continueFlag; 
    std::thread thread; 
}; 

std::vector<thread_data> threads; 

void work(int threadNum, std::atomic_flag &continueFlag) 
{ 
    while (continueFlag.test_and_set(std::memory_order_relaxed)) { 
     std::cout << "work" << threadNum << " "; 
     std::this_thread::sleep_for(std::chrono::milliseconds(10)); 
    } 
} 

void start() 
{ 
    const unsigned int numThreads = 2; 

    for (int i = 0; i < numThreads; i++) { 
     //////////////////////////////////////////////////////////////////// 
     //PROBLEM SECTOR 
     //////////////////////////////////////////////////////////////////// 
     thread_data td; 
     td.continueFlag.test_and_set(std::memory_order_relaxed); 

     td.thread = std::thread(&work, i, td.continueFlag); 

     threads.push_back(std::move(td)); 
     //////////////////////////////////////////////////////////////////// 
     //PROBLEM SECTOR 
     //////////////////////////////////////////////////////////////////// 
    } 
} 

void stop() 
{ 
    //Flag stop 
    for (auto &data : threads) { 
     data.continueFlag.clear(std::memory_order_relaxed); 
    } 
    //Join 
    for (auto &data : threads) { 
     data.thread.join(); 
    } 
    threads.clear(); 
} 

int main() 
{ 
    std::cout << "Start" << std::endl; 
    start(); 
    std::this_thread::sleep_for(std::chrono::milliseconds(200)); 
    std::cout << "Stop" << std::endl; 
    stop(); 
    std::cout << "Stopped." << std::endl; 

    return 0; 
} 

我的問題是「問題部門」上面。即創建線程。我無法圍繞如何實例化線程並將變量傳遞給工作線程。

現在的錯誤是引用此行threads.push_back(std::move(td));，錯誤號爲Error C2280 'thread_data::thread_data(const thread_data &)': attempting to reference a deleted function。

嘗試使用的unique_ptr這樣的：

 auto td = std::make_unique<thread_data>(); 
     td->continueFlag.test_and_set(std::memory_order_relaxed); 

     td->thread = std::thread(&work, i, td->continueFlag); 

     threads.push_back(std::move(td)); 

在行td->thread = std::thread(&work, i, td->continueFlag);給出錯誤std::atomic_flag::atomic_flag(const std::atomic_flag &)': attempting to reference a deleted function。我從根本上誤解了std :: atomic_flag的使用嗎？它確實既不可移動也不可複製？

Answer 1

我是差不多那裏用我的unique_ptr解決方案。我只是需要通過呼叫作爲一個std :: REF（）這樣：

std::vector<std::unique_ptr<thread_data>> threads; 

void start() 
{ 
    const unsigned int numThreads = 2; 

    for (int i = 0; i < numThreads; i++) { 
     auto td = std::make_unique<thread_data>(); 
     td->continueFlag.test_and_set(std::memory_order_relaxed); 
     td->thread = std::thread(&work, i, std::ref(td->continueFlag)); 

     threads.push_back(std::move(td)); 
    } 
} 

然而，薩姆的啓發以上我也想通一個非指針方式：

std::vector<thread_data> threads; 

void start() 
{ 
    const unsigned int numThreads = 2; 

    //create new vector, resize doesn't work as it tries to assign/copy which atomic_flag 
    //does not support 
    threads = std::vector<thread_data>(numThreads); 
    for (int i = 0; i < numThreads; i++) { 
     auto& t = threads.at(i); 
     t.continueFlag.test_and_set(std::memory_order_relaxed); 
     t.thread = std::thread(&work, i, std::ref(t.continueFlag)); 
    } 
} 

Answer 2

你的第一種方法實際上更接近事實。問題在於它將對本地for循環範圍內的對象的引用作爲參數傳遞給每個線程。但是，當然，一旦循環迭代結束，該對象超出範圍並被破壞，從而使每個線程都引用一個被銷燬的對象，導致未定義的行爲。

在創建線程後，沒有人關心您將對象移動到std::vector的事實。線程接收到對本地作用域對象的引用，這就是它所知道的。故事結局。

首先將對象移動到矢量中，然後傳遞給每個線程對std::vector中的對象的引用也不起作用。只要該載體在內部重新分配，作爲其自然增長的一部分，你就會陷入同樣的​​困境。

需要做的事情是在實際啓動任何std::thread之前首先創建整個threads陣列。如果宗教上遵循RAII原則，那隻不過是簡單地致電std::vector::resize()。

然後，在第二個循環中，遍歷完全烹飪的threads數組，然後爲數組中的每個元素生成一個std::thread。