/*
 * 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