C++ 同時プログラミング: マルチスレッド環境での例外処理をどのように処理するか?

// 使用互斥量实现线程安全异常处理
std::mutex m;
void handle_error() {
  std::unique_lock<std::mutex> lock(m);
  // 处理异常
}

// 使用 TLS 存储每个线程的异常信息
__thread std::exception_ptr exception_ptr;
void set_exception(const std::exception& e) {
  exception_ptr = std::make_exception_ptr(e);
}

// 在异步任务中处理异常
auto f = std::async(std::launch::async, []() {
  try {
    // 执行任务
  } catch (const std::exception& e) {
    std::cout << "Exception caught in async task: " << e.what() << std::endl;
  }
});

// 在主线程中检查异常
if (f.get()) {
  std::cout << "Async task completed successfully" << std::endl;
} else {
  std::cout << "Async task failed with exception" << std::endl;
}

#include <thread>
#include <vector>
#include <iostream>
#include <fstream>

using namespace std;

// TLS 存储下载失败的异常信息
__thread exception_ptr exception_ptr;

// 下载文件的线程函数
void download_file(const string& url, const string& path) {
  try {
    ofstream file(path, ios::binary);
    // 略：从 URL 下载数据并写入文件
  } catch (const exception& e) {
    exception_ptr = make_exception_ptr(e);
  }
}

// 主线程函数
int main() {
  // 创建下载线程
  vector<thread> threads;
  for (const auto& url : urls) {
    string path = "file_" + to_string(i) + ".txt";
    threads.emplace_back(download_file, url, path);
  }

  // 加入线程并收集异常信息
  for (auto& thread : threads) {
    thread.join();
    if (exception_ptr) {
      try {
        rethrow_exception(exception_ptr);
      } catch (const exception& e) {
        cerr << "File download failed: " << e.what() << endl;
      }
    }
  }

  return 0;
}