多线程 - C++中如何正确协作多个线程？

问题描述

问 题

我想写一个多线程的程序用于异步加载创建纹理图像，现在有这种设想，大致的先后顺序流程如图所示。其中线程B是主线程，不能阻塞，线程A是加载线程用于解析文件格式和拷贝数据。线程C是渲染线程，加载进来的图像纹理都通过线程C调用API存在显存中。
由于第一次写多线程程序，遇到一个问题：
应该如何协作同步这些线程，使得执行顺序正确，并保持相对高的效率，应该使用C++中哪些对应的函数和功能？需要实现哪些多线程的概念呢？如果可以的话求写一个大概的实现？

现在我同步线程是用了一堆bool类型的变量和while来阻塞线程AC，我感觉这样可能有问题。由于一些实现上的原因，方案本身不能修改，所以只问一下在代码实现上的问题，希望得到高手解答，非常感谢！

解决方案

每个线程有一个事件循环就可以了,有事件就处理,没事件就阻塞在队列.

事件循环可以用std::thread, std::mutex, std::condition_variable, std::queue, std::function组合起来,嫌麻烦直接用boost::asio::io_service,三个线程run不同的io_service.

用起来就是 A POST B, B POST C, C POST A.
需要注意的地方就是异步投递用智能指针引用资源,要不就纯拷贝,可以移动就移动,还有共享资源的竞争.
下面代码看起来比较难看,但是差不多就是这个意思.

event_loop A;
event_loop B;
event_loop C;

int main()
{
  std::thread([]() {
    A.run();
  }).detach();
  std::thread([]() {
    B.run();
  }).detach();
  std::thread([]() {
    C.run();
  }).detach();

  while(true) {
    std::string cmd_a;
    std::cin >> cmd_a;

    A.post([cmd_a]() {
      some_cmd a = parse(cmd_a);
      B.post([a]() {
        some_argv argv = parse(a);
        C.post([argv]() {
          some_img_path img_path = proc(argv);
          A.post([img_path]() {
            copy(img_path);
            C.post([img_path]() {
              close(img_path);
            });
          });
        });
      });
    });
  }
}

这篇关于多线程 - C++中如何正确协作多个线程？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！