ThreadSafeQueueTest.cpp File Reference

#include "Core/Multithreading/ThreadSafeQueue.hpp"
#include <boost/test/unit_test.hpp>
#include <cstring>
#include <thread>
#include <atomic>

Include dependency graph for ThreadSafeQueueTest.cpp:

Macros
#define	BOOST_TEST_MODULE   "ThreadSafeQueueTest"
#define	MAX_PUSHES   1000000

Functions
	BOOST_AUTO_TEST_CASE (ThreadSafeQueueTest)

Macro Definition Documentation

BOOST_TEST_MODULE

#define BOOST_TEST_MODULE   "ThreadSafeQueueTest"

MAX_PUSHES

#define MAX_PUSHES   1000000

Function Documentation

BOOST_AUTO_TEST_CASE()

BOOST_AUTO_TEST_CASE

(

ThreadSafeQueueTest

)

{
    ThreadSafeQueue<int> queue;
    std::thread *t[4];
    std::atomic<bool> go;
 
    for (int i = 0; i < MAX_PUSHES; i++)
        queue.push(std::move(i));
 
    BOOST_CHECK_EQUAL(queue.size(), MAX_PUSHES);
 
    t[0] = new std::thread([&queue, &go]() {
        while (!go);
        for (int i = 0; i < MAX_PUSHES; i++)
            queue.push(std::move(i));
    });
 
    t[1] = new std::thread([&queue, &go]() {
        while (!go);
        for (int i = 0; i < MAX_PUSHES; i++)
            queue.push(std::move(i));
    });
 
    t[2] = new std::thread([&queue, &go]() {
        while (!go);
        for (int i = 0; i < MAX_PUSHES; i++)
            queue.try_pop();
    });
 
    t[3] = new std::thread([&queue, &go]() {
        while (!go);
        for (int i = 0; i < MAX_PUSHES; i++)
            queue.try_pop();
    });
 
    go.exchange(true);
 
    t[0]->join();
    t[1]->join();
    t[2]->join();
    t[3]->join();
 
    delete t[0];
    delete t[1];
    delete t[2];
    delete t[3];
 
    BOOST_CHECK_EQUAL(queue.size(), MAX_PUSHES);
}

References go, MAX_PUSHES, ThreadSafeQueue< T >::push(), ThreadSafeQueue< T >::size(), and ThreadSafeQueue< T >::try_pop().

Here is the call graph for this function: