SimWorkers.cpp

#include "Headers.h"
#include "SimWorkers.h"

CSimWorkers::CSimWorkers(
    unsigned int    workersCount,
    unsigned int    workersQueueSize
    )
{
    this->workersCount = workersCount;
    this->workerLast = 0;

    // Create workers
    this->workers = new CSimWorker*[this->workersCount];
    for(unsigned int index = 0; index < this->workersCount; index++)
        this->workers[index] = new CSimWorker(index, workersQueueSize);
}

CSimWorkers::~CSimWorkers()
{
    for(unsigned int index = 0; index < this->workersCount; index++)
        delete this->workers[index];
    delete[] this->workers;
}

void CSimWorkers::Start()
{
    cout << "\nStarting simulator worker threads : ";
    // Start all workers
    for(unsigned int index = 0; index < this->workersCount; index++)
    {
        // Start worker
        this->workers[index]->Start();
        cout << index << " ";
    }
    cout << "done!" << endl;

#ifdef WORKER_PRIORITY
        cout << "Scheduling policies:" << endl;
        cout << "\tSCHED_OTHER min=" << sched_get_priority_min(SCHED_OTHER) << " max=" << sched_get_priority_max(SCHED_OTHER) << endl;
        cout << "\tSCHED_FIFO min=" << sched_get_priority_min(SCHED_FIFO) << " max=" << sched_get_priority_max(SCHED_FIFO) << endl;
        cout << "\tSCHED_RR min=" << sched_get_priority_min(SCHED_RR) << " max=" << sched_get_priority_max(SCHED_RR) << endl;
#endif
}

void CSimWorkers::Stop()
{
    cout << "\nStopping simulator worker threads : ";
    // Stop all workers
    for(unsigned int index = 0; index < this->workersCount; index++)
    {
        // Stop worker
        this->workers[index]->Stop();
        cout << index << " ";
    }
    cout << "done!" << endl;
}

void CSimWorkers::Enqueue(CSimWorkItem* item)
{
    // Enqueue a work item on the current worker
    this->workers[this->workerLast]->Enqueue(item);

    // Select next worker
    this->workerLast = (++this->workerLast) % this->workersCount;
}