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