Function stressTestThread

tests/boden/testDispatchQueue.cpp:163–196

    }

    void stressTestThread(std::weak_ptr<DispatchQueue> dispatchQueue, bool &end, std::atomic<int> &numCalls)
    {
        std::this_thread::sleep_for(1ms * rand() % 500);

        std::shared_ptr<int> nCalls = std::make_shared<int>(0);
        logstream(true) << "BombThread started ( id = 0x" << std::hex << std::this_thread::get_id() << " )";
        while (!end) {
            if (auto queue = dispatchQueue.lock())
                // std::this_thread::sleep_for(1ns * (rand() % 10000));
                switch (rand() % 3) {
                case 0:
                    queue->dispatchSync([&numCalls, nCalls]() {
                        numCalls++;
                        (*nCalls)++;
                    });
                    break;
                case 1:
                    queue->dispatchAsync([&numCalls, nCalls]() {
                        numCalls++;
                        (*nCalls)++;
                    });
                    break;
                case 2:
                    queue->dispatchAsyncDelayed(1ms * (rand() % 10), [&numCalls, nCalls]() {
                        numCalls++;
                        (*nCalls)++;
                    });
                    break;
                }
        }

        logstream(true) << "Thread Id = 0x" << std::hex << std::this_thread::get_id() << " Produced: " << std::dec
                        << *nCalls;
    }

    TEST(DispatchQueue, StressTest)
    {