blob: 5f1e26ad023168ba5d99dffcfd69f4f73539dd3f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
// Copyright (C) 2016 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only WITH Qt-GPL-exception-1.0
#include <QTest>
#include <QtCore/qfuturesynchronizer.h>
#include <QtCore/qfuture.h>
class tst_QFutureSynchronizer : public QObject
{
Q_OBJECT
private Q_SLOTS:
void construction();
void addFuture();
void cancelOnWait();
void clearFutures();
void futures();
void setFuture();
void waitForFinished();
};
void tst_QFutureSynchronizer::construction()
{
QFuture<void> future;
QFutureSynchronizer<void> synchronizer;
QFutureSynchronizer<void> synchronizerWithFuture(future);
QCOMPARE(synchronizer.futures().size(), 0);
QCOMPARE(synchronizerWithFuture.futures().size(), 1);
}
void tst_QFutureSynchronizer::addFuture()
{
QFutureSynchronizer<void> synchronizer;
synchronizer.addFuture(QFuture<void>());
QFuture<void> future;
synchronizer.addFuture(future);
synchronizer.addFuture(future);
QCOMPARE(synchronizer.futures().size(), 3);
}
void tst_QFutureSynchronizer::cancelOnWait()
{
QFutureSynchronizer<void> synchronizer;
QVERIFY(!synchronizer.cancelOnWait());
synchronizer.setCancelOnWait(true);
QVERIFY(synchronizer.cancelOnWait());
synchronizer.setCancelOnWait(false);
QVERIFY(!synchronizer.cancelOnWait());
synchronizer.setCancelOnWait(true);
QVERIFY(synchronizer.cancelOnWait());
}
void tst_QFutureSynchronizer::clearFutures()
{
QFutureSynchronizer<void> synchronizer;
synchronizer.clearFutures();
QVERIFY(synchronizer.futures().isEmpty());
synchronizer.addFuture(QFuture<void>());
QFuture<void> future;
synchronizer.addFuture(future);
synchronizer.addFuture(future);
synchronizer.clearFutures();
QVERIFY(synchronizer.futures().isEmpty());
}
void tst_QFutureSynchronizer::futures()
{
QFutureSynchronizer<void> synchronizer;
QList<QFuture<void> > futures;
for (int i=0; i<100; i++) {
QFuture<void> future;
futures.append(future);
synchronizer.addFuture(future);
}
QCOMPARE(futures.count(), synchronizer.futures().count());
}
void tst_QFutureSynchronizer::setFuture()
{
QFutureSynchronizer<void> synchronizer;
for (int i=0; i<100; i++) {
synchronizer.addFuture(QFuture<void>());
}
QCOMPARE(synchronizer.futures().size(), 100);
QFuture<void> future;
synchronizer.setFuture(future);
QCOMPARE(synchronizer.futures().size(), 1);
}
void tst_QFutureSynchronizer::waitForFinished()
{
QFutureSynchronizer<void> synchronizer;
for (int i=0; i<100; i++) {
synchronizer.addFuture(QFuture<void>());
}
synchronizer.waitForFinished();
const QList<QFuture<void> > futures = synchronizer.futures();
for (int i=0; i<100; i++) {
QVERIFY(futures.at(i).isFinished());
}
}
QTEST_MAIN(tst_QFutureSynchronizer)
#include "tst_qfuturesynchronizer.moc"
|
