commit

wangzhengquan

2020-07-14 8b4ddf10e71e1c8fabd33c72b282f7da65ff682f

 queue/include/array_lock_free_queue.h

@@ -4,6 +4,7 @@
#include <assert.h> // assert()
#include <sched.h>  // sched_yield()
#include "logger_factory.h"
#include "mem_pool.h"

/// @brief implementation of an array based lock free queue with support for 
///        multiple producers
@@ -90,7 +91,7 @@
    ,m_count(0)           //
#endif
{
    m_theQueue = (ELEM_T*)mm_malloc(Q_SIZE * sizeof(ELEM_T));
    m_theQueue = (ELEM_T*)mem_pool_malloc(Q_SIZE * sizeof(ELEM_T));

}

@@ -98,7 +99,7 @@
ArrayLockFreeQueue<ELEM_T>::~ArrayLockFreeQueue()
{
    // std::cout << "destroy ArrayLockFreeQueue\n";
    mm_free(m_theQueue);
    mem_pool_free(m_theQueue);
    
}