|
| Collection (ThreadWeaver::Private::Collection_Private *d) |
|
virtual void | addJob (JobPointer) |
| Append a job to the collection.
|
|
int | elementCount () const |
| Return the number of elements in the collection.
|
|
int | jobListLength () const |
|
Collection & | operator<< (const ThreadWeaver::JobPointer &job) |
| Add the job to this collection.
|
|
Collection & | operator<< (JobInterface &job) |
|
Collection & | operator<< (ThreadWeaver::JobInterface *job) |
| Add the job to this collection by pointer.
|
|
void | stop (ThreadWeaver::JobPointer job) |
| Stop processing, dequeue all remaining Jobs.
|
|
| Job () |
| Construct a Job.
|
|
| Job (Private::Job_Private *d) |
|
| ~Job () override |
| Destructor.
|
|
void | aboutToBeDequeued (QueueAPI *api) override |
| This Job is about the be dequeued from the weaver's job queue.
|
|
void | aboutToBeDequeued_locked (QueueAPI *api) override |
| Called from aboutToBeDequeued() while the mutex is being held.
|
|
void | aboutToBeQueued (QueueAPI *api) override |
| The job is about to be added to the weaver's job queue.
|
|
void | aboutToBeQueued_locked (QueueAPI *api) override |
| Called from aboutToBeQueued() while the mutex is being held.
|
|
void | assignQueuePolicy (QueuePolicy *) override |
| Assign a queue policy.
|
|
void | blockingExecute () override |
| Perform the job synchronously in the current thread.
|
|
void | execute (const JobPointer &job, Thread *) override |
| Perform the job.
|
|
Executor * | executor () const override |
| Returns the executor currently set on the Job.
|
|
bool | isFinished () const override |
| Returns true if the jobs's execute method finished.
|
|
QMutex * | mutex () const override |
| The mutex used to protect this job.
|
|
int | priority () const override |
| The queueing priority of the job.
|
|
QList< QueuePolicy * > | queuePolicies () const override |
| Return the queue policies assigned to this Job.
|
|
void | removeQueuePolicy (QueuePolicy *) override |
| Remove a queue policy from this job.
|
|
void | requestAbort () override |
| Abort the execution of the job.
|
|
Executor * | setExecutor (Executor *executor) override |
| Set the Executor object that is supposed to run the job.
|
|
void | setStatus (Status) override |
| Set the status of the Job.
|
|
Status | status () const override |
| The status of the job.
|
|
bool | success () const override |
| Return whether the Job finished successfully or not.
|
|
|
void | aboutToBeDequeued_locked (QueueAPI *api) override |
| Overload to dequeue the collection.
|
|
void | aboutToBeQueued_locked (QueueAPI *api) override |
| Overload to queue the collection.
|
|
ThreadWeaver::Private::Collection_Private * | d () |
|
const ThreadWeaver::Private::Collection_Private * | d () const |
|
void | execute (const JobPointer &job, Thread *) override |
| Overload the execute method.
|
|
JobPointer | jobAt (int i) |
| Return a ref-erence to the job in the job list at position i.
|
|
virtual int | jobListLength_locked () const |
| Return the number of jobs in the joblist.
|
|
void | run (JobPointer self, Thread *thread) override |
| Overload run().
|
|
Private::Job_Private * | d () |
|
const Private::Job_Private * | d () const |
|
void | defaultBegin (const JobPointer &job, Thread *thread) override |
| Perform standard tasks before starting the execution of a job.
|
|
void | defaultEnd (const JobPointer &job, Thread *thread) override |
| Perform standard task after the execution of a job.
|
|
virtual void | run (JobPointer self, Thread *thread) override=0 |
| The method that actually performs the job.
|
|
A Collection is a vector of Jobs that will be queued together.
In a Collection, the order of execution of the elements is not specified.
It is intended that the collection is set up first and then queued. After queuing, no further jobs should be added to the collection.