std::thread の利用でdetachした複数の無限ループのスレッドをすべて終了させる方法が知りたい

Question

質問内容

以下の処理内容部ですが、タイトル通りでstd::thread の利用で　detachした複数の無限ループのスレッドをすべて終了させる方法が知りたい　が知りたいです、現状は下記のように実装しているのですが本当はどうやって実装するのでしょうか？

知りたいこと

std::thread の利用でdetachした複数の無限ループのスレッドをすべて終了させる方法が知りたい

処理内容

以下の無限ループの処理のコードなのですが、websocketを用いた無限ループして処理を受け付ける処理ですそのコードのstatsu変数を用いて、メインスレッドから終了のキー入力を受け付けるとループ処理が抜けます、その後Close()関数ではすべてのスレッドの無限ループが抜けるまで無限ループを繰り返してその後すべて終われば無限ループを抜けて処理を抜けてmain関数の処理が終了してプログラムが終了するという処理です、

クロース処理関数

void Mastodon::Instance::Close()
{
    for(std::map<std::string,Status>::iterator itr = status.begin(); itr != status.end(); itr++)
    {
        itr->second.isLoop = false;        
    }

    bool isCheck = false;

    while(isCheck == false)
    {
        bool isRestart = false;
        for(std::map<std::string,Status>::iterator itr = status.begin(); itr != status.end(); itr++)
        {
            if(itr->second.isEixt == false)
            {
                isRestart = true;
                break;
            }          
        }

        if(isRestart == false)
        {
            std::cout<<"process exit"<<std::endl;
            ws_client.close().wait();
            break;
        }

    }
//    ws_client.close().wait();
}

websocketによる無限ループスレッド

void Mastodon::Instance::Stream(std::function<void(web::websockets::client::websocket_incoming_message)> func,web::http::uri_builder uri)
{
    status[uri.to_string()] = Status{false,false};
    if(ws_client.connect(uri.to_uri()).wait() == pplx::task_status::completed)
    {
        status[uri.to_string()] = Status{true,false};
        while(status[uri.to_string()].isLoop == true)
        {  
            ws_client.receive().then([func](web::websockets::client::websocket_incoming_message msg) 
            {
                if(msg.message_type() == web::websockets::client::websocket_message_type::text_message) 
                {
                    func(msg);
                } 
                else 
                {
                    if(msg.message_type() == web::websockets::client::websocket_message_type::ping) 
                    {
                        std::cout << "Ping " << msg.extract_string().get() << std::endl;
                    } 
                    else 
                    {
                        std::cout << "other type" << std::endl;
                    }
                }

            }).wait();
        }   
    }
    status[uri.to_string()] = Status{false,true};
}

Comments

[退会済みユーザー]

質問文は意味がないので読んでませんが、pthreadがnativeな環境でstd::threadのjoinの動きを見てみました。
$ cat hoge.sh
cat >hoge.cpp <<EOF
#include <thread>
#include <chrono>
#include <iostream>
int main(int argc, char* argv[]) {
std::thread t([]{
for(auto i = 0; i < 3; ++i) {
std::this_thread::sleep_for(std::chrono::seconds(1));
std::cout << "thread running..." << std::endl;
}
});
if (argc > 1) {
auto native_id = t.native_handle();
t.detach();
std::cout << native_id << std::endl;
std::cout << (pthread_join(native_id, nullptr) == EINVAL ? "EINVAL" : "not EINVAL") << std::endl;
} else {
t.join();
}
return 0;
}
EOF
g++ -pthread -Wall -pedantic -g hoge.cpp -o hoge
echo "join end"
./hoge
echo "detach end"
./hoge 1
$ bash hoge.sh
join end
thread running...
thread running...
thread running...
detach end
140420052784896
EINVAL
$
detachされたスレッドはpthread_joinすら失敗するようですね。

Answer 1

本件が何を問うているのかいまいちわかりませんが，「ループで激しく状態ポーリングすることに疑問がある」的な話であれば，
「condition_variable を使って待ち合わせできないか？」とかそういう話を検討すればよいのかもしれません．

Comments

[samidare_chan]

ありがとうございます。質問ですが、無限ループという処理もおかしいのでしょうか？また終了処理の正しい書き方を知りたいです。

[fana]

> 無限ループという処理もおかしいのでしょうか？

回答内で「ループで激しく状態ポーリングすること」と述べましたが，ループでCPUを酷使することはあまりよろしくないのではないかと．
で，「CPUを酷使せずに待つ」手段があるのならばそういうのを使うことを考えれば良いのではないか，というのがこの回答の趣旨です．

「条件が達成されるまで無限に待ち続けること」が良いのか否か（例えば，予期せぬ事態を想定してタイムアウトを設けたりとかする必要性があるかどうか）はあなたが決めることです．

> 正しい書き方

とかいう絶対的な正解があるわけではないでしょう．
あなたが満足いくような動きをするならば，それでOKです．

[fana]

そもそも私は std::thread を用いた経験があまり無いのですが，detach を用いた経験は全くありません．
なので，「detach したやつを待つための　正しい（というか良い）　やり方」みたいなのはちょっとわかんないです．

ただ，「終了を待ちたいならば detach せずに join を用いれば良いのでは？」とか思います．
そもそも何故 detach するのですか？