86 lines
1.7 KiB
C++
86 lines
1.7 KiB
C++
#include <QtTest>
|
|
|
|
#include <QtConcurrent/qtconcurrentrun.h>
|
|
|
|
#include "utils/lfqueue.h"
|
|
#include "tst_lfqueue.h"
|
|
|
|
|
|
|
|
void TestLFQueue::setSize_data()
|
|
{
|
|
QTest::addColumn<int>("size");
|
|
QTest::addColumn<bool>("result");
|
|
|
|
QTest::newRow("-1") << -1 << false;
|
|
QTest::newRow("0") << 0 << true;
|
|
QTest::newRow("10") << 10 << true;
|
|
QTest::newRow("2000") << 20000 << true;
|
|
|
|
}
|
|
|
|
|
|
void TestLFQueue::setSize()
|
|
{
|
|
QFETCH(int, size);
|
|
QFETCH(bool, result);
|
|
|
|
LFQueue<void*> queue;
|
|
QCOMPARE(queue.setSize(size), result);
|
|
}
|
|
|
|
|
|
void readerThread(LFQueue<int>* pQueue_p, int pSize, bool pSleep) {
|
|
int* val_p;
|
|
|
|
for(int i=0; i<pSize ; i++) {
|
|
while(! (val_p = pQueue_p->peek()) );
|
|
QVERIFY(val_p);
|
|
|
|
QCOMPARE(*val_p, i);
|
|
pQueue_p->dequeue();
|
|
|
|
if(pSleep)
|
|
QThread::msleep(1);
|
|
}
|
|
}
|
|
|
|
|
|
void TestLFQueue::exchange_data()
|
|
{
|
|
QTest::addColumn<int>("size");
|
|
QTest::addColumn<bool>("writerSleep");
|
|
QTest::addColumn<bool>("readerSleep");
|
|
|
|
QTest::newRow("nosleep") << 1000 << false << false;
|
|
QTest::newRow("readersleep") << 1000 << false << true;
|
|
QTest::newRow("writersleep") << 1000 << true << false;
|
|
}
|
|
|
|
|
|
void TestLFQueue::exchange()
|
|
{
|
|
LFQueue<int> queue;
|
|
QFETCH(int, size);
|
|
QFETCH(bool, writerSleep);
|
|
QFETCH(bool, readerSleep);
|
|
|
|
int* val_p;
|
|
QCOMPARE(queue.setSize(2), true);
|
|
|
|
QFuture<void> thread = QtConcurrent::run(readerThread, &queue, size, readerSleep);
|
|
|
|
for(int i=0; i<size ; i++) {
|
|
while(! (val_p = queue.get()) );
|
|
QVERIFY(val_p);
|
|
|
|
*val_p = i;
|
|
queue.queue();
|
|
|
|
if(writerSleep)
|
|
QThread::msleep(1);
|
|
}
|
|
|
|
thread.waitForFinished();
|
|
}
|