Async: implement progress reporting through future

This is a simplified progress reporting, since it does not report progress
of ther overcall Job chain, but only of individual tasks, which makes it
only really useful on one-task Jobs.

TODO: propagate subjob progress to the Future user gets copy of
TODO: compound progress reporting (be able to report a progress of the overall
      Job chain)

3 files changed, 26 insertions, 1 deletions

diff --git a/async/src/async.h b/async/src/async.h
index 6cb3825..c316639 100644
--- a/async/src/async.h
+++ b/async/src/async.h
@@ -56,7 +56,7 @@
  *   valid until the task is complete. To abort a job it has to be killed through the future handle.
  *   TODO: Can we tie the lifetime of the executor to the last available future handle?
  *
- * TODO: Progress reporting through future
+ * TODO: Composed progress reporting
  * TODO: Possibility to abort a job through future (perhaps optional?)
  * TODO: Support for timeout, specified during exec call, after which the error handler gets called with a defined errorCode.
  */
diff --git a/async/src/future.cpp b/async/src/future.cpp
index 970060b..4f3cd80 100644
--- a/async/src/future.cpp
+++ b/async/src/future.cpp
@@ -102,6 +102,21 @@ QString FutureBase::errorMessage() const
     return d->errorMessage;
 }
 
+void FutureBase::setProgress(int processed, int total)
+{
+    setProgress((qreal) processed / total);
+}
+
+void FutureBase::setProgress(qreal progress)
+{
+    for (auto watcher : d->watchers) {
+        if (watcher) {
+            watcher->futureProgressCallback(progress);
+        }
+    }
+}
+
+
 
 void FutureBase::addWatcher(FutureWatcherBase* watcher)
 {
@@ -128,6 +143,11 @@ void FutureWatcherBase::futureReadyCallback()
     Q_EMIT futureReady();
 }
 
+void FutureWatcherBase::futureProgressCallback(qreal progress)
+{
+    Q_EMIT futureProgress(progress);
+}
+
 void FutureWatcherBase::setFutureImpl(const FutureBase &future)
 {
     d->future = future;
diff --git a/async/src/future.h b/async/src/future.h
index bc18f00..32c1015 100644
--- a/async/src/future.h
+++ b/async/src/future.h
@@ -54,6 +54,9 @@ public:
     int errorCode() const;
     QString errorMessage() const;
 
+    void setProgress(qreal progress);
+    void setProgress(int processed, int total);
+
 protected:
     class PrivateBase : public QSharedData
     {
@@ -197,12 +200,14 @@ class FutureWatcherBase : public QObject
 
 Q_SIGNALS:
     void futureReady();
+    void futureProgress(qreal progress);
 
 protected:
     FutureWatcherBase(QObject *parent = nullptr);
     virtual ~FutureWatcherBase();
 
     void futureReadyCallback();
+    void futureProgressCallback(qreal progress);
 
     void setFutureImpl(const Async::FutureBase &future);