15bee33076
This should allow concurrency in the plugins to be independent from their container. Contains also some work on the system for registering plugins.
47 lines
1 KiB
C++
47 lines
1 KiB
C++
#ifndef RUNCONTROLLABLETASK_H
|
|
#define RUNCONTROLLABLETASK_H
|
|
/** From answer by Hatter
|
|
*
|
|
* https://stackoverflow.com/questions/5423058/qfuture-that-can-be-cancelled-and-report-progress
|
|
*/
|
|
|
|
#include <QFutureInterface>
|
|
#include <QRunnable>
|
|
#include <QThreadPool>
|
|
#include "ControllableTask.h"
|
|
#include "TaskControl.h"
|
|
|
|
template <typename T>
|
|
class RunControllableTask : public QFutureInterface<T> , public QRunnable
|
|
{
|
|
public:
|
|
RunControllableTask(ControllableTask<T>* tsk) : task(tsk) { }
|
|
virtual ~RunControllableTask() { delete task; }
|
|
|
|
QFuture<T> start()
|
|
{
|
|
this->setRunnable(this);
|
|
this->reportStarted();
|
|
QFuture<T> future = this->future();
|
|
QThreadPool::globalInstance()->start(this, /*m_priority*/ 0);
|
|
return future;
|
|
}
|
|
|
|
void run()
|
|
{
|
|
if (this->isCanceled()) {
|
|
this->reportFinished();
|
|
return;
|
|
}
|
|
TaskControl control(this);
|
|
result = this->task->run(control);
|
|
if (!this->isCanceled()) {
|
|
this->reportResult(result);
|
|
}
|
|
this->reportFinished();
|
|
}
|
|
|
|
T result;
|
|
ControllableTask<T> *task;
|
|
};
|
|
#endif // RUNCONTROLLABLETASK_H
|