lasersquad/LogEngine2: Простая, быстрая и функциональная C++ библиотека для логирования. Проста в освоении, платформо-независимая, header-only, малое количество кода, работает из коробки.

include/SynchronizedQueue.h

162 строки3 KB

lasersquad0

Added concept of default logger

22 апр 2025, 23:18

22 апр 2025, 23:183b509bd

/*
 * SynchronizedQueue.h
 *
 * Copyright 2025, LogEngine2 Project. All rights reserved.
 *
 * See the COPYING file for the terms of usage and distribution.
 */

#ifndef SYNCHRONIZED_QUEUE_H
#define SYNCHRONIZED_QUEUE_H

#include <mutex>
#include <condition_variable>
#include "Common.h"
#include "DynamicArrays.h"


template<class T>
class SafeQueue : private THArray<T>
{
private:
    std::mutex mtx;
    std::condition_variable cv;

public:
    SafeQueue(uint capacity) { this->SetCapacity(capacity); }

    T WaitForElement()
    {
        std::unique_lock<std::mutex> lock(mtx);
        while (this->Count() == 0)
            cv.wait(lock);

        //    T out = this->GetValue(0);
        //    this->DeleteValue(0);

        return this->PopFront(); // TODO PopFront causes all the other elements to be moved in memory. Think of container that does not require moving elements during PopFront
    }

    void PushElement(T in_element)
    {
        std::lock_guard<std::mutex> lock(mtx);

        this->AddValue(in_element);
        cv.notify_one();
    }

    // wait till Queue becomes empty
    void WaitEmptyQueue()
    {
        //std::lock_guard<std::mutex> lock(mtx);
        while(this->Count() > 0)
            std::this_thread::sleep_for(std::chrono::milliseconds(500));
    }
};


//-------------------------------------------------------------------
// Old implementation based on WinAPI and pthread calls
//-------------------------------------------------------------------

/*
template<class T>
class SynchronizedQueue : private THArray<T>
{
	//MUTEX_TYPE ListMutex;
    std::recursive_mutex mtx;
    
#ifdef WIN32
	HANDLE ListSemaphore;
//#endif
#else
//#ifdef HAVE_PTHREAD_H
	int            ListSemaphoreValue;
	pthread_cond_t ListSemaphore;
#endif

public:
	SynchronizedQueue();
	virtual ~SynchronizedQueue();

	T WaitForElement();
	void PushElement(T in_element);
};

template<class T>
T SynchronizedQueue<T>::WaitForElement()
{
#ifdef WIN32
    WaitForSingleObject(ListSemaphore, INFINITE);
    //ENTER_CRITICAL_SECTION(ListMutex);

    //#endif
#else
    //#ifdef HAVE_PTHREAD_H
    //ENTER_CRITICAL_SECTION(ListMutex);
    while (ListSemaphoreValue == 0)
        pthread_cond_wait(&ListSemaphore, &ListMutex);

    ListSemaphoreValue--;
#endif

    mutexguard lock(mtx);
    T out = this->GetValue((const int)0);//front();
    this->DeleteValue(0);//pop_front();
    //LEAVE_CRITICAL_SECTION(ListMutex);

    return out;
}

template<class T>
SynchronizedQueue<T>::SynchronizedQueue()
{
    //INIT_CRITICAL_SECTION(ListMutex);
#ifdef WIN32
    ListSemaphore = CreateSemaphore(nullptr, 0, MAXLONG, nullptr);
//#endif
#else
//#ifdef HAVE_PTHREAD_H
    pthread_cond_init(&ListSemaphore, NULL);
    ListSemaphoreValue = 0;
    this->SetCapacity(100);
#endif
}

template<class T>
SynchronizedQueue<T>::~SynchronizedQueue()
{
#ifdef WIN32
    CloseHandle(ListSemaphore);
//#endif
#else
//#ifdef HAVE_PTHREAD_H
    pthread_cond_destroy(&ListSemaphore);
#endif

   // DELETE_CRITICAL_SECTION(ListMutex);
}


template<class T>
void SynchronizedQueue<T>::PushElement(T in_element)
{
    //ENTER_CRITICAL_SECTION(ListMutex);
    mutexguard lock(mtx);
    this->AddValue(in_element);//push_back(in_element);

#ifdef WIN32
    ReleaseSemaphore(ListSemaphore, 1, nullptr);
//#endif 
#else
//#ifdef HAVE_PTHREAD_H
    ListSemaphoreValue++;
    pthread_cond_signal(&ListSemaphore);
#endif
    //LEAVE_CRITICAL_SECTION(ListMutex);
}
*/



#endif //SYNCHRONIZED_QUEUE_H