Qt线程
使用Qt开发多线程应用,这里有一篇必看的官网博客:You are doing it wrong,文章讲了QThread使用时常犯的错误。总结下来,QThread的正确使用思路有两种:
- 继承QThread,重新实现run(),将需要次线程执行的代码写入run()即可。
- 继承QObject实现功能,使用线程时创建一个QThread对象,将QObject对象通过moveToThread()移入该线程。
update:今天看Qt5的文档,发现官方文档已经添加了示例代码,直接看这个就可以了。
Qt并发
并发是更高层的接口,可以不去操作底层的线程,也不需要关心信号和槽所在的线程,比较容易上手。Qt Concurrent使用方法很简单,如果是普通函数,调用方式为:
QFuture<T> QtConcurrent::run(Function function, ... )
如果是类的成员函数,需要传入对象指针。比如上面的例子,相当于默认传入了一个全局指针:
QtConcurrent::run(QThreadPool::globalInstance(), function, ...);
C++ 11的异步和线程
对比一下C++标准的异步实现:
#include <iostream>
#include <future>
#include <thread>
std::future<int> ft;
void async_func(){
// 开始异步执行
ft = std::async(std::launch::async, [](){
std::cout << "async start" <<endl;
std::this_thread::sleep_for(std::chrono::seconds(3));
return 2046;
});
}
void testAsync(){
std::future_status status;
do {
// 等一秒查一下状态
status = ft.wait_for(std::chrono::seconds(1));
if (status == std::future_status::deferred) {
std::cout << "deferred" << std::endl;
} else if (status == std::future_status::timeout) {
std::cout << "timeout" << std::endl;
} else if (status == std::future_status::ready) {
std::cout << "ready" << std::endl;
std::cout << ft.get() << std::endl;
}
} while(status != std::future_status::ready);
}
下面是线程的简单示例(互斥锁):
#include <thread>
#include <mutex>
#include <chrono>
std::mutex mlock;
void func()
{
mlock.lock(); // 可以去掉锁后观察区别
std::cout << "in...." << std::this_thread::get_id() << std::endl;
std::this_thread::sleep_for(std::chrono::seconds(2));
std::cout << "out..." << std::this_thread::get_id() << std::endl;
mlock.unlock();
}
void testThread(){
std::thread t1(func);
std::thread t2(func);
t1.join();
t2.join();
}