workerthreadtest.cpp

Go to the documentation of this file.

/**********************************************************************
 * LeechCraft - modular cross-platform feature rich internet client.
 * Copyright (C) 2006-2014  Georg Rudoy
 *
 * Distributed under the Boost Software License, Version 1.0.
 * (See accompanying file LICENSE or copy at https://www.boost.org/LICENSE_1_0.txt)
 **********************************************************************/
 
#include "workerthreadtest.h"
#include <QtTest>
#include <workerthreadbase.h>
 
QTEST_MAIN (LC::Util::WorkerThreadTest)
 
namespace LC::Util
{
    struct Worker
    {
        QThread * const Main_;
        int& Val_;
 
        explicit Worker (int *val, QThread *main)
        : Main_ { main }
        , Val_ { *val }
        {
        }
 
        void Increment (int n)
        {
            qDebug () << QThread::currentThread ();
            QVERIFY (QThread::currentThread () != Main_);
 
            Val_ += n;
        }
 
        void Quit (QEventLoop& loop)
        {
            QTimer::singleShot (0, &loop, &QEventLoop::quit);
        }
    };
 
    void WorkerThreadTest::testWorkerThread ()
    {
        QEventLoop loop;
        auto spin = [&loop]
        {
            QTimer::singleShot (100, &loop, &QEventLoop::quit);
            loop.exec ();
        };
 
        qDebug () << Q_FUNC_INFO << QThread::currentThread ();
 
        int val = 0;
        WorkerThread<Worker> worker { &val, QThread::currentThread () };
        worker.SetQuitWait (1000);
        worker.start ();
 
        worker.SetPaused (true);
        worker.ScheduleImpl (&Worker::Increment, 1);
        worker.ScheduleImpl (&Worker::Increment, 2);
        worker.ScheduleImpl (&Worker::Increment, 3);
 
        spin ();
        QCOMPARE (val, 0);
 
        worker.SetPaused (false);
 
        spin ();
        QCOMPARE (val, 6);
 
        worker.ScheduleImpl (&Worker::Increment, 10);
 
        spin ();
        QCOMPARE (val, 16);
    }
}