/*
 * Copyright 2015, Axel Dörfler, axeld@pinc-software.de.
 * Distributed under the terms of the MIT License.
 */
#ifndef WORKER_H
#define WORKER_H


#include <Job.h>
#include <JobQueue.h>


using namespace BSupportKit;
using BSupportKit::BPrivate::JobQueue;


class Worker {
public:
                                                                Worker(JobQueue& queue);
        virtual                                         ~Worker();

                        status_t                        Init();

protected:
        virtual status_t                        Process();
        virtual bigtime_t                       Timeout() const;
        virtual const char*                     Name() const;
        virtual status_t                        Run(BJob* job);

private:
        static  status_t                        _Process(void* self);

protected:
                        thread_id                       fThread;
                        JobQueue&                       fJobQueue;
};


class MainWorker : public Worker {
public:
                                                                MainWorker(JobQueue& queue);

protected:
        virtual bigtime_t                       Timeout() const;
        virtual const char*                     Name() const;
        virtual status_t                        Run(BJob* job);

private:
                        int32                           fMaxWorkerCount;
};


#endif // WORKER_H