Stabilize tst_QFutureWatcher::warnRace

1 files changed, 12 insertions, 2 deletions

diff --git a/tests/auto/qfuturewatcher/tst_qfuturewatcher.cpp b/tests/auto/qfuturewatcher/tst_qfuturewatcher.cpp
index 8b52761..183f62c 100644
--- a/tests/auto/qfuturewatcher/tst_qfuturewatcher.cpp
+++ b/tests/auto/qfuturewatcher/tst_qfuturewatcher.cpp
@@ -47,6 +47,7 @@
 #include <qfuturewatcher.h>
 #include <qtconcurrentrun.h>
 #include <qtconcurrentmap.h>
+#include "../../shared/util.h"
 
 #ifndef QT_NO_CONCURRENT_TEST
 #include <private/qfutureinterface_p.h>
@@ -891,6 +892,13 @@ class DummyObject : public QObject {
     Q_OBJECT
 public slots:
     void dummySlot() {}
+public:
+    static void function(QWaitCondition *cond)
+    {
+        QMutex m;
+        QMutexLocker lock(&m);
+        cond->wait(&m);
+    }
 };
 
 void tst_QFutureWatcher::warnRace()
@@ -900,14 +908,16 @@ void tst_QFutureWatcher::warnRace()
 #endif
     QFutureWatcher<void> watcher;
     DummyObject object;
+    QWaitCondition cond;
 
-    QFuture<void> future = QtConcurrent::run(sleeper);
+    QFuture<void> future = QtConcurrent::run(DummyObject::function, &cond);
     watcher.setFuture(future);
+    QTRY_VERIFY(future.isStarted());
     connect(&watcher, SIGNAL(finished()), &object, SLOT(dummySlot()));
+    cond.wakeAll();
     future.waitForFinished();
 }
 
-
 #include "tst_qfuturewatcher.moc"
 
 #else