blob: 62ad4f872a64da5c70882a9f54d53e1b159f4f23 (
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
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
|
// Copyright (C) 2016 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only
#include <QTest>
#include <QtCore/qfuturesynchronizer.h>
#include <QtCore/qfuture.h>
class tst_QFutureSynchronizer : public QObject
{
Q_OBJECT
private Q_SLOTS:
void construction();
void setFutureAliasingExistingMember();
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::setFutureAliasingExistingMember()
{
//
// GIVEN: a QFutureSynchronizer with one QFuture:
//
QFutureSynchronizer synchronizer(QtFuture::makeReadyValueFuture(42));
//
// WHEN: calling setFuture() with an alias of the QFuture already in `synchronizer`:
//
for (int i = 0; i < 2; ++i) {
// The next line triggers -Wdangling-reference, but it's a FP because
// of implicit sharing. We cannot keep a copy of synchronizer.futures()
// around to avoid the warning, as the extra copy would cause a detach()
// of m_futures inside setFuture() with the consequence that `f` no longer
// aliases an element in m_futures, which is the goal of this test.
QT_WARNING_PUSH
#if defined(Q_CC_GNU_ONLY) && Q_CC_GNU >= 1301
QT_WARNING_DISABLE_GCC("-Wdangling-reference")
#endif
const auto &f = synchronizer.futures().constFirst();
QT_WARNING_POP
synchronizer.setFuture(f);
}
//
// THEN: it didn't crash
//
QCOMPARE(synchronizer.futures().size(), 1);
QCOMPARE(synchronizer.futures().constFirst().result(), 42);
}
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.size(), synchronizer.futures().size());
}
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"
|
