Lang/C++/C++11/thread の履歴(No.3)

Top/Lang/C++/C++11/thread

目次†

目次
初めに
thread の作成
thread 終了を待機する
thread を手放す
thread の識別
現在の thread の処理を明け渡す
現在の thread をスリープする
並行実行できる thread の数を取得する
thread を排他制御する
リソースのロックを管理する
複数のリソースをロックする
ロックせずに吐いたアクセスする
スレッドセーフに1度だけ関数を呼び出す
条件変数を使用する
thread をまたいで値や例外を受け渡す
非同期処理をする
スレッドローカル変数を使用する

↑

初めに†

C++11 では thread がサポートされている。→ std::thread class を使う
gcc では build 時に -pthread オプションを要求される場合がある

↑

thread の作成†

関数 foo(), bar() をそれぞれ別の thread で実行する

// 排他出力処理
mutex print_mutex;
void print( const string &s ) {
    lock_guard<mutex> lk(print_mutex);
    cout << s << endl;
}

void foo() {
    print( "foo" );
}

void bar() {
    print( "bar" );
}

// foo(), bar() をそれぞれ別の thread で実行
thread th1( foo );
thread th2( bar );
th1.join();
th2.join();

関数や関数オブジェクトの呼び出し演算子が仮引数を取る場合、 std::thread のコンストラクタの第2引数以降に関数や関数オブジェクトの関数呼び出し演算子へ与える実引数を渡す。
std::thread のコンストラクタに渡された実引数は、受け取る関数が参照渡しとして宣言されていたとしても、コピーされて std::thread クラスのオブジェクト内に保存される。
- 上記コピーを避けたい場合は、実引数をムーブするか、 std::ref() 関数でくるんで渡す。
- std::ref() を使用した場合、作成した thread に参照が渡されるので、元のオブジェクトの寿命に注意すること。
thread 内で例外が発生し、 catch されないまま thread 外に送出されると、std::terminate() が呼び出され、プログラムが強制終了する。

↑

thread 終了を待機する†

thread の終了を待機するところで std::thread::join() を呼ぶ。

    std::thread th1( foo() );
    th1.join();
    cout << "th1 is joined" << endl;

join() 呼び出しが完了するまで、 join() の実行元スレッドはブロックされる。
join() の呼び出しが完了すると、そのオブジェクト（上記例では th1）はどのスレッドも管理していない状態になる。
既に join() の呼び出しが完了しているオブジェクトに対して join() を呼び出すと、 std::errc::invalid_argument をエラーコードに設定した std::system_error 例外が送出される。
std::thread::joinable() の返り値を見ることによって、そのオブジェクトの join() を問題なく呼び出せるかどうかを確認することが出来る。
join() 呼び出し可能なオブジェクトが破棄される場合、 std::thread::detach() や std::thread::join() が自動的に呼び出されず、 std::terminate() が呼び出されてプログラムが即時に終了することになっている。
join() 可能なオブジェクトは、破棄される前に必ず join() するか detach() を呼び出すようにしなければならない。

↑

thread を手放す†

void srd::thread::detach() を実行する

using namespace std;
void foo() {
    // 時間の掛かる処理
    ...
}

void bar() {
    thread th1( foo() );
    th1.detach();    // スレッドを手放す
}
// 関数 bar() が終了しても、スレッド foo() は別スレッドにて実行中

std::thread::detach() が呼び出されると、そのオブジェクト（上記例の th1）はどのスレッドも管理していない状態になる。
既に detach() が呼び出されたオブジェクトに対して detach() を呼び出すと、 std::errc::invalid_argument をエラーコードに設定された std::system_error 例外が送出される。
std::exit() が呼ばれると、実行中のスレッドがあってもプログラムは終了する。この時、実行中のスレッドから、プログラム終了に伴い破棄されたオブジェクトにアクセスすると、未定義の動作を引き起こす。

↑

thread の識別†

std::thread::id std::thread::get_id() を呼ぶ

void foo( ostringstream &os ) {
    os << "foo(): " << this_thread::get_id() << endl;
}

void bar( ostringstream &os ) {
    os << "bar(): " << this_thread::get_id() << endl;
}

ostringstream os_foo;
ostringstream os_bar;

thread th1( foo(), ref( os_foo ) );
thread th2( bar(), ref( os_bar ) );

// それぞれの thread ID を得る
thread::id id1 = th1.get_id();
thread::id id2 = th2.get_id();
thread::id id3 = this_thread::get_id();

assert( id1 != is2 );
assert( id1 != is3 );
assert( id2 != is3 );

th1.join();
th2.join();

cout << os_foo.str();
cout << os_bar.str();
cout << "main thread : " << this_thread::get_id() << endl;

↑