Method randomCalls

tests/concurrent_queue_test/concurrent_queue_test.cpp:666–697

}

void ConcurrentQueueTest::randomCalls()
{
    QFETCH(const int, queueThreadCount);
    QFETCH(const int, userThreadCount);
    QVERIFY(userThreadCount > 0);
    QFETCH(const bool, boostEnqueueOperationWeight);

    const auto printer = makeMessagePrinter(queueThreadCount);

    ConcurrentQueue queue(queueThreadCount);
    printer.printStartedMessage();

    randomEngineProvider.resetEngines(userThreadCount);

    std::vector<std::thread> userThreads;
    userThreads.reserve(userThreadCount - 1);
    for (int id = 1; id < userThreadCount; ++id) {
        userThreads.emplace_back(RandomCaller(queue, total, id, queueThreadCount,
                                              randomEngineProvider.engine(id),
                                              boostEnqueueOperationWeight));
    }
    RandomCaller(queue, total, primaryThreadId, queueThreadCount,
                 randomEngineProvider.engine(primaryThreadId),
                 boostEnqueueOperationWeight)();

    for (auto &t : userThreads)
        t.join();

    waitAndPrint(queue, printer);

    QCOMPARE(total.load(), 0);
}

QTEST_APPLESS_MAIN(ConcurrentQueueTest)