/*
 * Copyright 2013-2014, Haiku, Inc. All Rights Reserved.
 * Distributed under the terms of the MIT License.
 *
 * Authors:
 *              Ingo Weinhold <ingo_weinhold@gmx.de>
 */
#ifndef JOB_QUEUE_H
#define JOB_QUEUE_H


#include <pthread.h>

#include "Job.h"


class JobQueue {
public:
                        class Filter;

public:
                                                                JobQueue();
                                                                ~JobQueue();

                        status_t                        Init();
                        void                            Close();

                        bool                            QueueJob(Job* job);
                                                                        // acquires a reference, if successful
                        Job*                            DequeueJob();
                                                                        // returns a reference

                        void                            DeleteJobs(Filter* filter);

private:
                        typedef DoublyLinkedList<Job> JobList;

private:
                        pthread_mutex_t         fMutex;
                        pthread_cond_t          fNewJobCondition;
                        bool                            fMutexInitialized;
                        bool                            fNewJobConditionInitialized;
                        JobList                         fJobs;
                        bool                            fClosed;
};


class JobQueue::Filter {
public:
        virtual                                         ~Filter();

        virtual bool                            FilterJob(Job* job) = 0;
};


#endif  // JOB_QUEUE_H