打印當前數

Question

我想打印數據隊列的元素的當前數目在每一秒在多線程的程序是這樣的：

queue<int> products; 
void print(ostream& s) 
{ 
    cout << s.rdbuf(); 
    cout.flush(); 
    s.clear(); 
} 
void printQueue() 
{ 
    while(true) 
    { 
     this_thread::sleep_for(chrono::seconds(1)); 
     print(stringstream() << "Number of prouducts: " << products.size() << "\n"); 
    } 
} 

void producer(int i) 
{ //adds data into queue in thread safe manner 
} 
void consumer(int i) 
{/*removes data from queue in thread safe manner*/} 

int main() 
{ 
    vector<thread> thrds; 

    for(int i = 0; i < 5; ++i) 
     thrds.push_back(thread(producer, i)); 

    for(int i = 0; i < 4; ++i) 
     thrds.push_back(thread(consumer, i)); 

    thrds.push_back(thread(printQueue)); 

    for(auto& t : thrds) 
     t.join(); 
} 
return 0; 
} 

打印隊列 - 這是功能線程安全？

Answer 1

有兩種資源被多個線程訪問：

• std::cout
• products

的std::cout典型實現相對性能穩定的多個線程被訪問，但他們並不能保證該輸出不是例如交錯。不過，在形式上沒有同步，所以你的寫作不是線程安全的。

關於products，您的訪問有不被任何互斥被保護的，這也使得這些訪問非線程安全的。在一些地方你只能閱讀尺寸並不重要。並不是說這個讀取訪問可能會破壞任何內容，但結果（即，當您看到更改和看到的內容）仍未定義。

摘要：使用互斥鎖來保護共享資源。

Answer 2

身爲std::queue合同printQueue線程安全與否depeneds。對於他們公開方法的每個集裝箱特定線程的行爲就屬於下列主要類別之一：

• 線程同步
• 線程安全
• 線程不安全的（可以產生一個種族）

第三個意思是說這個調用永遠不能用在不受保護的環境中 - 也就是說，在這個調用正在發生時，不能有任何其他方法調用容器的其他方法。 1和2之間的區別在於，對於第一個選項，您保證在另一個線程中修改後（在合理的延遲時間內）修改後讀取新值。線程安全不會給你這個保證，但仍然聲明調用這個方法不會讓你的程序暴露於數據競爭，並且你保證讀取舊值或新值，但是沒有未定義的行爲。

對於標準容器作爲std::queue，他們所有的常量方法是線程安全的，而非常量的方法是線程安全的。由於您將調用線程不安全推送，因此您需要使用外部同步來保護您的訪問。