18

c++11 でスレッドをテストするための簡単なプログラムを作成しましたが、std::cout期待どおりに動作しません。

class Printer
{
public:
    void exec()
    {
        mutex m;
        m.lock();
        cout<<"Hello  "<<this_thread::get_id()<<endl;
        chrono::milliseconds duration( 100 );
        this_thread::sleep_for( duration );
        m.unlock();

    }
};

int main()
{
    Printer printer;

    thread firstThread([&printer](){
        while(1)
            printer.exec();

    });
    thread secondThread([&printer](){
        while(1)
            printer.exec();
    });

    firstThread.join();
    secondThread.join();     
}

結果の一部:

Hello 11376
Hello 16076
Hello 16076
Hello Hello 11376
16076
Hello 11376
,....

スレッドをロックするためにミューテックスを使用したため、2 つのスレッドがstd::cout同時に実行されている理由がわかりません。何が起こっているのか誰か説明できますか!?

4

4 に答える 4

18

受け入れられた答えは正しいです。ただし、懸念事項を分離することをお勧めします。

  1. std::coutスレッドセーフな方法で印刷する方法が必要です。
  2. スレッドで実行して起動するには、オブジェクト/ファンクター/関数を作成する必要があります。

これは私が使用するユーティリティで、引数を収集std::coutして a の下にストリーミングすることに集中していstatic std::mutexます。

#include <iostream>
#include <mutex>

std::ostream&
print_one(std::ostream& os)
{
    return os;
}

template <class A0, class ...Args>
std::ostream&
print_one(std::ostream& os, const A0& a0, const Args& ...args)
{
    os << a0;
    return print_one(os, args...);
}

template <class ...Args>
std::ostream&
print(std::ostream& os, const Args& ...args)
{
    return print_one(os, args...);
}

std::mutex&
get_cout_mutex()
{
    static std::mutex m;
    return m;
}

template <class ...Args>
std::ostream&
print(const Args& ...args)
{
    std::lock_guard<std::mutex> _(get_cout_mutex());
    return print(std::cout, args...);
}

このコードは 以外のストリームに再利用できますstd::coutが、上記は のみを対象とするように特化されていstd::coutます。これにより、Printer::exec()大幅に簡素化できるようになりました。

void exec()
{
    print("Hello ", std::this_thread::get_id(), '\n');
    std::this_thread::sleep_for(std::chrono::milliseconds(100));
}

これで、スレッド セーフな方法でPrinter使用できるcoutようになり、簡素化された (たとえば、独自のmutexforを維持する必要がないcout) だけでなく、他のすべての型と関数も使用できcout、安全に相互運用できます。print関数自体が を維持するようになり、その事実はのすべてのクライアントmutexから離れてカプセル化されます。print

于 2013-08-16T20:40:46.930 に答える
7

ハワード・ヒナントの実装よりもエレガントであることがわかった、この質問で与えられたニコラスからのトリックを共有しています。アイデアは、一時的な ostringstream オブジェクトを作成し、デストラクタに保護コードを配置することです。

/** Thread safe cout class
  * Exemple of use:
  *    PrintThread{} << "Hello world!" << std::endl;
  */
class PrintThread: public std::ostringstream
{
public:
    PrintThread() = default;

    ~PrintThread()
    {
        std::lock_guard<std::mutex> guard(_mutexPrint);
        std::cout << this->str();
    }

private:
    static std::mutex _mutexPrint;
};

std::mutex PrintThread::_mutexPrint{};

std::coutその後、任意のスレッドから通常の として使用できます。

PrintThread{} << "val = " << 33 << std::endl;

オブジェクトは定期的にデータを収集しますstd::ostringstream。昏睡状態に達するとすぐに、オブジェクトは破壊され、収集されたすべての情報がフラッシュされます。

于 2017-01-11T23:58:45.077 に答える
1

保護された出力に使用されるグローバルstd::mutex cout_mutex;(名前空間のどこか) を考慮することができstd::coutます。必ず使用してくださいstd::lock<std::mutex>（ミューテックスのロックを解除し、例外の安全性を確保することを忘れないようにしてください）。

于 2013-08-16T17:44:21.307 に答える