龙空技术网

Qt 多线程之QtConcurrent(一)

长安9218 55

前言:

而今咱们对“qt数据库连接池”大致比较讲究,看官们都想要学习一些“qt数据库连接池”的相关文章。那么小编同时在网摘上收集了一些对于“qt数据库连接池””的相关内容,希望咱们能喜欢,同学们快快来了解一下吧!

之前的三种方法都需要建立子类继承QT基类,用起来较为麻烦,而且对于共享数据的保护需要使用低级线程原语,即mutexes(互斥锁), read-write locks(读写锁), wait conditions(等待条件), or semaphores(信号量),这无疑是要非常小心的。QtConcurrent可以避免这些问题,而且可以根据机器的cpu自动调整线程数,因此比较常用。接下来介绍QtConcurrent的使用方法。

QtConcurrent仅支持接受纯函数或者lambda表达式,不支持信号和槽,如果需要监听任务执行结果可以通过与QFuture和QFutureWatcher配合来达到。

QtConcurrent的常用方法有QtConcurrent::run()、QtConcurrent::map()、QtConcurrent::filter()。map和filter还有其衍生的方法,例如还有mapped()、mappedReduced()、filtered()、filteredReduced。下面通过使用这几个方法来了解QtConcurrent的使用方法,代码均写在main.cpp中。

QFuture

QFuture类表示异步计算的结果,使用Qt Concurrent框架中的API启用。QFuture允许线程针对一个或多个结果进行同步,这些结果将在稍后的时间点准备就绪。结果可以是具有默认构造函数和副本构造函数的任何类型。接下来介绍一些常用函数:

T result() const;//返回序号为0的结果

T resultAt(int index) const;//返回序号为index的结果

int resultCount() const;//返回结果总数

QList<T> results() const;//返回全部结果,用QList<T>存储

QFuture允许线程针对一个或多个结果进行同步,这些结果将在稍后的时间点准备就绪。结果可以是具有默认构造函数和副本构造函数的任何类型。如果在调用result(),resultAt()或results()函数时结果不可用,则QFuture将等待,直到结果变为可用。可以使用isResultReadyAt()函数来确定结果是否准备就绪。QFuture还提供了Java样式的迭代器(QFutureIterator)和STL样式的迭代器(QFuture :: const_iterator)。使用这些迭代器是获取结果的另一种方法。

void cancel();//取消异步计算

void setPaused(bool paused);//暂停计算

void pause();//效果同setPaused(true);

void resume();//效果同setPaused(false);

void togglePaused();效果与setPaused相反

QFuture提供了以上与运行计算进行交互的方法。例如,可以使用cancel()函数取消计算。要暂停计算,请使用setPaused()函数或pause(),resume()或togglePaused()便利函数之一。请注意,并非所有异步计算都可以取消或暂停。例如,不能取消QtConcurrent :: run()返回的future。但是QtConcurrent :: mappedReduced()返回的Future可以。

int QFuture::progressValue() const;//返回当前进度的值,介于progressMinimum()和progressMaxmum()之间

int QFuture::progressMaximum() const;//返回进度最大值

int QFuture::progressMinimum() const;//返回进度最小值

QString QFuture::progressText() const;//返回异步计算报告的进度的文本表示形式。注意,并非所有计算都提供进度的文本表示,因此,该函数可能会返回空字符串。

进度信息由progressValue(),progressMinimum(),progressMaximum()和progressText()函数提供。 waitForFinished()函数使调用线程阻塞并等待计算完成,确保所有结果均可用。可以使用isCanceled(),isStarted(),isFinished(),isRunning()或isPaused()函数查询QFuture表示的计算状态。QFuture是轻量级引用计数类,可以按值传递。QFuture <void>专门用于不包含任何结果获取功能。任何QFuture <T>都可以分配或复制到QFuture <void>中。如果仅需要状态或进度信息,而无需实际结果数据,则此功能很有用。

QFutureWatcher

要使用信号和插槽与正在运行的任务进行交互,则需要使用QFutureWatcher。QFutureWatcher类允许使用信号和插槽监视QFuture。QFutureWatcher提供有关QFuture的信息和通知。使用setFuture()函数开始监视特定的QFuture。 future()函数返回带有setFuture()的Future集。

为了方便起见,QFutureWatcher中还提供了一些函数:progressValue(),progressMinimum(),progressMaximum(),progressText(),isStarted(),isFinished(),isRunning(),isCanceled(),isPaused(),waitForFinished (),result()和resultAt()。 以及一些槽函数cancel(),setPaused(),pause(),resume()和togglePaused()。

状态更改通过started(),finished(),canceled(),paused(),resumed(),resultReadyAt()和resultReadyAt()信号进行报告。从progressRangeChanged(),void progressValueChanged()和progressTextChanged()信号提供进度信息。节流控制由setPendingResultsLimit()函数提供。当待处理的resultReadyAt()或resultsReadyAt()信号的数量超过限制时,由Future表示的计算将自动受到限制。一旦待处理信号的数量下降到限制以下,计算将恢复。

实例演示

上述代码是在mainwindow中添加的,这个没有要求,只要能在主函数里运行即可。此处用到的mapped函数会在后面说明。运行结果如下:

运行结果

通过运行结果可以发现,QtConccurent管理的线程实际是从线程池分配线程资源的,而绑定QFutureWatcher的槽是在主线程中执行的。

Result At 序号对应resultAt(int index)函数的处理结果。

Watcher =>后面的是主线程ID和地址,最后的数字对应progressValue()函数的返回值,即进度是多少,此处的范围是0-6。

标签: #qt数据库连接池