问题描述
我想写一个多线程的程序用于异步加载创建纹理图像,现在有这种设想,大致的先后顺序流程如图所示。其中线程B是主线程,不能阻塞,线程A是加载线程用于解析文件格式和拷贝数据。线程C是渲染线程,加载进来的图像纹理都通过线程C调用API存在显存中。由于第一次写多线程程序,遇到一个问题:应该如何协作同步这些线程,使得执行顺序正确,并保持相对高的效率,应该使用C++中哪些对应的函数和功能?需要实现哪些多线程的概念呢?如果可以的话求写一个大概的实现?
现在我同步线程是用了一堆bool类型的变量和while来阻塞线程AC,我感觉这样可能有问题。由于一些实现上的原因,方案本身不能修改,所以只问一下在代码实现上的问题,希望得到高手解答,非常感谢!
问题解答
回答1:每个线程有一个事件循环就可以了,有事件就处理,没事件就阻塞在队列.
事件循环可以用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); }); });}); }); }); }}回答2:
最好说明一下所用的c++版本(c++98,c++11,c++14...?)以及所用的操作系统(windows,Linux...?)。不同的组合,有不同的多线程机制。