SimpleJobCoordinator Class Reference

#include <simple_job_coordinator.h>

Classes
struct	Job

Public Member Functions
void	end ()
Job *	loadConsume () const
void	participate ()
void	runOne (Job *job)
	SimpleJobCoordinator ()
void	storeRelease (Job *job)

Private Attributes
QWaitCondition	condVar
Atomic< quint64 >	m_job
QMutex	mutex

Detailed Description

Definition at line 23 of file simple_job_coordinator.h.

Constructor & Destructor Documentation

SimpleJobCoordinator()

SimpleJobCoordinator::SimpleJobCoordinator ( )

inline

Definition at line 40 of file simple_job_coordinator.h.

                           : m_job(quint64(NULL))
    {
    }

Member Function Documentation

end()

void SimpleJobCoordinator::end ( )

inline

Definition at line 96 of file simple_job_coordinator.h.

    {
        {
            QMutexLocker guard(&mutex);
            m_job.store(1, Release);
        }
 
        condVar.wakeAll();
    }

References condVar, m_job, mutex, Release, and Atomic< T >::store().

loadConsume()

Job * SimpleJobCoordinator::loadConsume ( ) const

inline

Definition at line 44 of file simple_job_coordinator.h.

    {
        return (Job*) m_job.load(Consume);
    }

References Consume, Atomic< T >::load(), and m_job.

participate()

void SimpleJobCoordinator::participate ( )

inline

Definition at line 59 of file simple_job_coordinator.h.

    {
        quint64 prevJob = quint64(NULL);
 
        for (;;) {
            quint64 job = m_job.load(Consume);
            if (job == prevJob) {
                QMutexLocker guard(&mutex);
 
                for (;;) {
                    job = m_job.loadNonatomic(); // No concurrent writes inside lock
                    if (job != prevJob) {
                        break;
                    }
 
                    condVar.wait(&mutex);
                }
            }
 
            if (job == 1) {
                return;
            }
 
            reinterpret_cast<Job*>(job)->run();
            prevJob = job;
        }
    }

References condVar, Consume, Atomic< T >::load(), Atomic< T >::loadNonatomic(), m_job, and mutex.

runOne()

void SimpleJobCoordinator::runOne ( Job * job )

inline

Definition at line 87 of file simple_job_coordinator.h.

    {
#ifdef SANITY_CHECK
        KIS_ASSERT_RECOVER_NOOP(job != (Job*) m_job.load(Relaxed));
#endif // SANITY_CHECK
        storeRelease(job);
        job->run();
    }

References KIS_ASSERT_RECOVER_NOOP, Atomic< T >::load(), m_job, Relaxed, SimpleJobCoordinator::Job::run(), and storeRelease().

storeRelease()

void SimpleJobCoordinator::storeRelease ( Job * job )

inline

Definition at line 49 of file simple_job_coordinator.h.

    {
        {
            QMutexLocker guard(&mutex);
            m_job.store(quint64(job), Release);
        }
 
        condVar.wakeAll();
    }

References condVar, m_job, mutex, Release, and Atomic< T >::store().

Member Data Documentation

condVar

QWaitCondition SimpleJobCoordinator::condVar

private

Definition at line 37 of file simple_job_coordinator.h.

m_job

Atomic<quint64> SimpleJobCoordinator::m_job

private

Definition at line 35 of file simple_job_coordinator.h.

mutex

QMutex SimpleJobCoordinator::mutex

private

Definition at line 36 of file simple_job_coordinator.h.

---

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

• libs/image/3rdparty/lock_free_map/simple_job_coordinator.h