diff options
author | Dan Vrátil <dvratil@redhat.com> | 2014-12-11 11:07:04 +0100 |
---|---|---|
committer | Dan Vrátil <dvratil@redhat.com> | 2014-12-11 11:07:20 +0100 |
commit | 67d47d893bc582fbd06da8bd93a1c416fa314ca6 (patch) | |
tree | a30004b1c974baef1a700f6647eae2cf43e9f06b /async/src/async.cpp | |
parent | 0fc8477dec805f943e829a662a9e42337ce628ab (diff) | |
download | sink-67d47d893bc582fbd06da8bd93a1c416fa314ca6.tar.gz sink-67d47d893bc582fbd06da8bd93a1c416fa314ca6.zip |
Prototype of Async library
Diffstat (limited to 'async/src/async.cpp')
-rw-r--r-- | async/src/async.cpp | 67 |
1 files changed, 67 insertions, 0 deletions
diff --git a/async/src/async.cpp b/async/src/async.cpp new file mode 100644 index 0000000..5c89e53 --- /dev/null +++ b/async/src/async.cpp | |||
@@ -0,0 +1,67 @@ | |||
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 "async.h" | ||
23 | |||
24 | #include <QCoreApplication> | ||
25 | #include <QDebug> | ||
26 | #include <QEventLoop> | ||
27 | |||
28 | |||
29 | using namespace Async; | ||
30 | |||
31 | FutureBase::FutureBase() | ||
32 | : mFinished(false) | ||
33 | , mWaitLoop(nullptr) | ||
34 | { | ||
35 | |||
36 | } | ||
37 | |||
38 | FutureBase::FutureBase(const Async::FutureBase &other) | ||
39 | : mFinished(other.mFinished) | ||
40 | , mWaitLoop(other.mWaitLoop) | ||
41 | { | ||
42 | } | ||
43 | |||
44 | void FutureBase::setFinished() | ||
45 | { | ||
46 | mFinished = true; | ||
47 | if (mWaitLoop && mWaitLoop->isRunning()) { | ||
48 | mWaitLoop->quit(); | ||
49 | } | ||
50 | } | ||
51 | |||
52 | bool FutureBase::isFinished() const | ||
53 | { | ||
54 | return mFinished; | ||
55 | } | ||
56 | |||
57 | void FutureBase::waitForFinished() | ||
58 | { | ||
59 | if (mFinished) { | ||
60 | return; | ||
61 | } | ||
62 | |||
63 | mWaitLoop = new QEventLoop; | ||
64 | mWaitLoop->exec(QEventLoop::ExcludeUserInputEvents); | ||
65 | delete mWaitLoop; | ||
66 | mWaitLoop = 0; | ||
67 | } | ||