[C++] 289 FLTK : ChatGPTアプリの製作 その18 マルチスレッド処理の試み std::thread

[M1 Mac, Monterey 12.6.3, clang 13.0.0, FLTK 1.3.8, ChatGPT Plus, NO IDE]

std::threadもうまくいきませんでした。アプリが落ちることはなく、送受信終了時にようやくタイムが表示されます。

void sendCB(Fl_Widget*, void*) {
    sendBool = true;

    std::thread sendMain([](){
        sendCB_A();
    });

    std::thread stopwatch([](){
        timerCallback(nullptr);
    });

    sendMain.join();
    stopwatch.join();

}

[C++] 288 FLTK : ChatGPTアプリの製作 その17 マルチスレッド処理の試み Cpp-Taskflowライブラリ

[M1 Mac, Monterey 12.6.3, clang 13.0.0, FLTK 1.3.8, ChatGPT Plus, NO IDE]

Cpp-Taskflowというライブラリを試してみましたが、これもダメでした。

#include "taskflow/taskflow.hpp"

void sendCB_A(){
    (送受信に関するコード)
}

void sendCB_B(){
    // ストップウォッチ開始
    resetBtn -> do_callback();
    startBtn -> do_callback();

    sendBool = true; // timerCallback関数を停止させるため
}

void sendCB_C(){
    // ストップウォッチ停止
    stopBtn -> do_callback();
}

void sendCB_D(){
    timerCallback(nullptr);
}


void sendCB(Fl_Widget*, void*) {
    tf::Executor executor;
    tf::Taskflow taskflow;

    auto [A, B, C, D] = taskflow.emplace(
        [] () { sendCB_A(); },
        [] () { sendCB_B(); },
        [] () { sendCB_C(); },
        [] () { sendCB_D(); }
    );

    A.succeed(B); // ストップウォッチ開始後、送受信開始
    D.succeed(B); // ストップウォッチ開始後、timerCallback関数開始
    C.succeed(A); // 送受信終了後、ストップウォッチ停止
 
    executor.run(taskflow).wait();
}
ストップウォッチは動作しているがGUIへ反映せず

[C++] 287 FLTK : ChatGPTアプリの製作 その16 マルチスレッド処理の試み Fl::add_timeout関数

[M1 Mac, Monterey 12.6.3, clang 13.0.0, FLTK 1.3.8, ChatGPT Plus, NO IDE]

FLTKのコールバック関数とストップウォッチ表示のマルチスレッド処理について試した内容をまとめておきます。

・Fl::add_timeout関数
指定された時間間隔でコールバック関数を呼び出します。ストップウォッチだけなら動作するが、送受信が加わるとウォッチの数値は動かず、送受信終了時に表示される。

int main(int argc, char **argv) {

   	<中略>

   	window->end();  
   	window->show(argc, argv);

    Fl::add_timeout(0.01, timerCallback);

   	return Fl::run();
}
void timerCallback(void*) {
    // 経過時間を取得して、Fl_Outputに表示する
    double elapsedTime = stopwatch.elapsedTime();
    stringstream ss;
    // ss << std::fixed << elapsedTime;
    ss << std::fixed << std::setprecision(1) << elapsedTime;
    // cout << "経過時間: " << ss.str() << endl;
    timeShow->value(ss.str().c_str());

    window -> redraw();

    // タイマーを再起動する
    Fl::repeat_timeout(0.01, timerCallback);
}
void sendCB2(Fl_Widget*, void*) {
    // ストップウォッチ開始
    resetBtn -> do_callback();
    startBtn -> do_callback();
}
シングルスレッドの場合(マルチスレッドでもこのようにしたい)