summaryrefslogtreecommitdiffstats
path: root/async/src/future.cpp
diff options
context:
space:
mode:
authorDan Vrátil <dvratil@redhat.com>2014-12-14 12:59:22 +0100
committerDan Vrátil <dvratil@redhat.com>2014-12-14 13:03:38 +0100
commit664396b0e550910cea50b7852066a04cc7fec3bd (patch)
tree544f9e8206bd498fd16047211a833d01d65ac864 /async/src/future.cpp
parent925d3bd3159820c0eae356fe4d3af54cb16ae1e3 (diff)
downloadsink-664396b0e550910cea50b7852066a04cc7fec3bd.tar.gz
sink-664396b0e550910cea50b7852066a04cc7fec3bd.zip
Async: make the processing truly asynchronous
Now calling exec() starts the first job and returns a pending Future immediately. Caller can then use Async::FutureWatcher to wait for the future to become finished, i.e. for all jobs to finish execution.
Diffstat (limited to 'async/src/future.cpp')
-rw-r--r--async/src/future.cpp57
1 files changed, 57 insertions, 0 deletions
diff --git a/async/src/future.cpp b/async/src/future.cpp
new file mode 100644
index 0000000..48c7417
--- /dev/null
+++ b/async/src/future.cpp
@@ -0,0 +1,57 @@
1/*
2 * Copyright 2014 Daniel Vrátil <dvratil@redhat.com>
3 *
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public License as
6 * published by the Free Software Foundation; either version 2 of
7 * the License or (at your option) version 3 or any later version
8 * accepted by the membership of KDE e.V. (or its successor approved
9 * by the membership of KDE e.V.), which shall act as a proxy
10 * defined in Section 14 of version 3 of the license.
11 *
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License
18 * along with this program. If not, see <http://www.gnu.org/licenses/>.
19 *
20 */
21
22#include "future.h"
23
24using namespace Async;
25
26FutureBase::FutureBase()
27 : mFinished(false)
28 , mWaitLoop(nullptr)
29{
30}
31
32FutureBase::FutureBase(const Async::FutureBase &other)
33 : mFinished(other.mFinished)
34 , mWaitLoop(other.mWaitLoop)
35{
36}
37
38FutureBase::~FutureBase()
39{
40}
41
42bool FutureBase::isFinished() const
43{
44 return mFinished;
45}
46
47FutureWatcherBase::FutureWatcherBase(QObject *parent)
48 : QObject(parent)
49{
50}
51
52FutureWatcherBase::~FutureWatcherBase()
53{
54}
55
56
57#include "future.moc" \ No newline at end of file