#include "DatabaseWorker.h"

Public Member Functions
	DatabaseWorker (ProducerConsumerQueue< SQLOperation * > newQueue, MySQLConnection connection)

	~DatabaseWorker ()

Private Member Functions
void	WorkerThread ()

	DatabaseWorker (DatabaseWorker const &right)=delete

DatabaseWorker &	operator= (DatabaseWorker const &right)=delete

Private Attributes
ProducerConsumerQueue< SQLOperation * > *	_queue

MySQLConnection *	_connection

std::thread	_workerThread

std::atomic< bool >	_cancelationToken

Detailed Description

Constructor & Destructor Documentation

◆ DatabaseWorker() [1/2]

DatabaseWorker::DatabaseWorker	(	ProducerConsumerQueue< SQLOperation * > *	newQueue,
		MySQLConnection *	connection
	)

{
    _connection = connection;
    _queue = newQueue;
    _cancelationToken = false;
    _workerThread = std::thread(&DatabaseWorker::WorkerThread, this);
}

References _cancelationToken, _connection, _queue, _workerThread, and WorkerThread().

◆ ~DatabaseWorker()

DatabaseWorker::~DatabaseWorker ( )

{
    _cancelationToken = true;
 
    _queue->Cancel();
 
    _workerThread.join();
}

References _cancelationToken, _queue, _workerThread, and ProducerConsumerQueue< T >::Cancel().

◆ DatabaseWorker() [2/2]

DatabaseWorker::DatabaseWorker ( DatabaseWorker const & right )

privatedelete

Member Function Documentation

◆ operator=()

DatabaseWorker & DatabaseWorker::operator= ( DatabaseWorker const & right )

privatedelete

◆ WorkerThread()

void DatabaseWorker::WorkerThread ( )

private

{
    if (!_queue)
        return;
 
    for (;;)
    {
        SQLOperation* operation = nullptr;
 
        _queue->WaitAndPop(operation);
 
        if (_cancelationToken || !operation)
            return;
 
        operation->SetConnection(_connection);
        operation->call();
 
        delete operation;
    }
}