Job Queue class to handle a queue of unique jobs to be processed sequentially. More...

#include <JobManager.h>

Inheritance diagram for CJobQueue:

Collaboration diagram for CJobQueue:

Public Member Functions
	CJobQueue (bool lifo=false, unsigned int jobsAtOnce=1, CJob::PRIORITY priority=CJob::PRIORITY_LOW)
	CJobQueue constructor. More...

	~CJobQueue () override
	CJobQueue destructor Cancels any in-process jobs, and destroys the job queue. More...

bool	AddJob (CJob *job)
	Add a job to the queue On completion of the job, destruction of the job queue or in case the job could not be added successfully, the CJob object will be destroyed. More...

template<typename F >
void	Submit (F &&f)
	Add a function f to this job queue.

void	CancelJob (const CJob *job)
	Cancel a job in the queue Cancels a job in the queue. Any job currently being processed may complete after this call has completed, but OnJobComplete will not be performed. If the job is only queued then it will be removed from the queue and deleted. More...

void	CancelJobs ()
	Cancel all jobs in the queue Removes all jobs from the queue. Any job currently being processed may complete after this call has completed, but OnJobComplete will not be performed. More...

bool	IsProcessing () const
	Check whether the queue is processing a job.

void	OnJobComplete (unsigned int jobID, bool success, CJob *job) override
	The callback used when a job completes. More...

void	OnJobAbort (unsigned int jobID, CJob *job) override
	The callback used when a job will be aborted. More...

Public Member Functions inherited from IJobCallback
virtual	~IJobCallback ()=default
	Destructor for job call back objects. More...

virtual void	OnJobProgress (unsigned int jobID, unsigned int progress, unsigned int total, const CJob *job)
	An optional callback function that a job may call while processing. More...

Protected Member Functions
bool	QueueEmpty () const
	Returns if we still have jobs waiting to be processed NOTE: This function does not take into account the jobs that are currently processing.

Detailed Description

Job Queue class to handle a queue of unique jobs to be processed sequentially.

Holds a queue of jobs to be processed sequentially, either first in,first out or last in, first out. Jobs are unique, so queueing multiple copies of the same job (based on the CJob::operator==) will not add additional jobs.

Classes should subclass this class and override OnJobCallback should they require information from the job.

See also: CJob and IJobCallback

Constructor & Destructor Documentation

◆ CJobQueue()

CJobQueue::CJobQueue	(	bool	lifo = `false`,
		unsigned int	jobsAtOnce = `1`,
		CJob::PRIORITY	priority = `CJob::PRIORITY_LOW`
	)

CJobQueue constructor.

Parameters

lifo	whether the queue should be processed last in first out or first in first out. Defaults to false (first in first out)
jobsAtOnce	number of jobs at once to process. Defaults to 1.
priority	priority of this queue.

See also: CJob

◆ ~CJobQueue()

CJobQueue::~CJobQueue ( )

override

CJobQueue destructor Cancels any in-process jobs, and destroys the job queue.

See also: CJob

Member Function Documentation

◆ AddJob()

bool CJobQueue::AddJob ( CJob * job )

Add a job to the queue On completion of the job, destruction of the job queue or in case the job could not be added successfully, the CJob object will be destroyed.

Parameters

job	a pointer to the job to add. The job should be subclassed from CJob.

Returns: True if the job was added successfully, false otherwise. In case of failure, the passed CJob object will be deleted before returning from this method.

See also: CJob

◆ CancelJob()

void CJobQueue::CancelJob ( const CJob * job )

Cancel a job in the queue Cancels a job in the queue. Any job currently being processed may complete after this call has completed, but OnJobComplete will not be performed. If the job is only queued then it will be removed from the queue and deleted.

Parameters

job	a pointer to the job to cancel. The job should be subclassed from CJob.

See also: CJob

◆ CancelJobs()

void CJobQueue::CancelJobs ( )

Cancel all jobs in the queue Removes all jobs from the queue. Any job currently being processed may complete after this call has completed, but OnJobComplete will not be performed.

See also: CJob

◆ OnJobAbort()

void CJobQueue::OnJobAbort	(	unsigned int	jobID,
		CJob *	job
	)

overridevirtual

The callback used when a job will be aborted.

CJobQueue implementation will cleanup the internal processing queue and then queue the next job at the job manager, if any.

Parameters

jobID	the unique id of the job (as retrieved from CJobManager::AddJob)
job	the job that has been aborted.

See also: CJobManager, IJobCallback and CJob

Reimplemented from IJobCallback.

◆ OnJobComplete()

void CJobQueue::OnJobComplete	(	unsigned int	jobID,
		bool	success,
		CJob *	job
	)

overridevirtual

The callback used when a job completes.

CJobQueue implementation will cleanup the internal processing queue and then queue the next job at the job manager, if any.

Parameters

jobID	the unique id of the job (as retrieved from CJobManager::AddJob)
success	the result from the DoWork call
job	the job that has been processed.

See also: CJobManager, IJobCallback and CJob

Implements IJobCallback.

Reimplemented in CVideoLibraryQueue, CGUIWindowFileManager, and CGUIDialogSubtitles.

The documentation for this class was generated from the following files:

xbmc/utils/JobManager.h
xbmc/utils/JobManager.cpp

Public Member Functions

Protected Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ CJobQueue()

◆ ~CJobQueue()

Member Function Documentation

◆ AddJob()

◆ CancelJob()

◆ CancelJobs()

◆ OnJobAbort()

◆ OnJobComplete()