SimWorker.h

#pragma once

#include "SimWorkItem.h"

#ifdef WIN32
#elif POSIX
#include <sched.h>
#include <errno.h>
#endif

class CSimWorker
{
public:
    enum EWorkerState
    {
        WORKER_STATE_STOPPED = 0,
        WORKER_STATE_STARTING = 1,
        WORKER_STATE_STARTED_IDLE = 2,
        WORKER_STATE_STARTED_BUSY = 3,
        WORKER_STATE_STOPPING = 4
    };

private:
    unsigned int        id;
    EWorkerState        state;

    unsigned int        queueSize;
    unsigned int        queueCount;
    unsigned int        queuePtr;
    CSimWorkItem**      queue;

#ifdef WIN32
    HANDLE              threadHandle;   // Thread handle
    DWORD               threadId;       // Thread id
    CRITICAL_SECTION    threadMutex;    // Thread mutex : used to synchronize shared variables with the worker thread

    HANDLE              stateHandle;    // State event handle
    HANDLE              workHandle;     // Work event handle
#elif POSIX
    pthread_t           threadHandle;   // Thread handle
    pthread_mutex_t     threadMutex;    // Thread mutex

    pthread_cond_t      stateCond;      // State condition
    pthread_mutex_t     stateMutex;     // State mutex

    pthread_cond_t      workCond;       // Work condition
    pthread_mutex_t     workMutex;      // Work mutex
#endif

public:
    CSimWorker(
        unsigned int    id,
        unsigned int    queueSize
        );
    ~CSimWorker();
    
    void                Start();
    void                Stop();

    void                Enqueue(CSimWorkItem* item);

private:

#ifdef WIN32
    static DWORD WINAPI Execute(__in LPVOID parameter);
#elif POSIX
    static void*        Execute(void* parameter);
#endif
};