#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

Constructor & Destructor Documentation

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

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

Here is the call graph for this function:

DatabaseWorker::~DatabaseWorker ( )

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

Here is the call graph for this function:

DatabaseWorker::DatabaseWorker ( DatabaseWorker const & right )

privatedelete

Member Function Documentation

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

privatedelete

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;
  }
 }