wait for thread terminations

XG_CancelFromWordsDialog.hpp

@@ -109,6 +109,8 @@ class XG_CancelFromWordsDialog : public XG_Dialog
             ::KillTimer(hwnd, uTimerID);
             // 計算時間を求めるために、終了時間を取得する。
             xg_dwlTick2 = ::GetTickCount64();
+            // スレッドを待つ。
+            XgWaitForThreads();
             // ダイアログを終了する。
             ::EndDialog(hwnd, IDOK);
         } else {

XG_CancelGenBlacksDialog.hpp

@@ -97,6 +97,8 @@ class XG_CancelGenBlacksDialog : public XG_Dialog
             ::KillTimer(hwnd, uTimerID);
             // 計算時間を求めるために、終了時間を取得する。
             xg_dwlTick2 = ::GetTickCount64();
+            // スレッドを待つ。
+            XgWaitForThreads();
             // ダイアログを終了する。
             ::EndDialog(hwnd, IDOK);
             // スレッドを閉じる。

XG_CancelSmartSolveDialog.hpp

@@ -125,6 +125,8 @@ class XG_CancelSmartSolveDialog : public XG_Dialog
             ::KillTimer(hwnd, uTimerID);
             // 計算時間を求めるために、終了時間を取得する。
             xg_dwlTick2 = ::GetTickCount64();
+            // スレッドを待つ。
+            XgWaitForThreads();
             // 解を求めようとした後の後処理。
             XgEndSolve();
             // ダイアログを終了する。

XG_CancelSolveDialog.hpp

@@ -145,6 +145,8 @@ class XG_CancelSolveDialog : public XG_Dialog
             ::KillTimer(hwnd, uTimerID);
             // 計算時間を求めるために、終了時間を取得する。
             xg_dwlTick2 = ::GetTickCount64();
+            // スレッドを待つ。
+            XgWaitForThreads();
             // 解を求めようとした後の後処理。
             XgEndSolve();
             // ダイアログを終了する。

XG_CancelSolveNoAddBlackDialog.hpp

@@ -132,6 +132,8 @@ class XG_CancelSolveNoAddBlackDialog : public XG_Dialog
             ::KillTimer(hwnd, uTimerID);
             // 計算時間を求めるために、終了時間を取得する。
             xg_dwlTick2 = ::GetTickCount64();
+            // スレッドを待つ。
+            XgWaitForThreads();
             // 解を求めようとした後の後処理。
             XgEndSolve();
             // ダイアログを終了する。

crossword_generation.hpp

@@ -119,17 +119,6 @@ inline void reset() noexcept {
 #endif
 }
 
-// 生成済みかキャンセル済みかを待つ。このような待ち方はモダンではない。
-// ここのコードはモダンな方法に置き換えられるべき。
-inline void wait_for_threads(int num_threads = get_num_processors(), int retry_count = 3) {
-    constexpr int INTERVAL = 100;
-    for (int i = 0; i < retry_count; ++i) {
-        if (s_generated || s_canceled)
-            break;
-        std::this_thread::sleep_for(std::chrono::milliseconds(INTERVAL));
-    }
-}
-
 // 連結性を判定。
 template <typename t_string>
 inline bool
@@ -2031,6 +2020,7 @@ struct non_add_block_t {
             try {
                 // スレッドを生成。切り離す。
                 std::thread t(generate_proc, pboard, pwords, i);
+                xg_ahThreads[i] = t.native_handle();
                 t.detach();
             } catch (std::system_error&) {
                 delete pboard;