/home/maxime/Projets/Mixxx/1.10/mixxx/src/engine/engineworkerscheduler.h

Go to the documentation of this file.

#ifndef ENGINEWORKERSCHEDULER_H
#define ENGINEWORKERSCHEDULER_H

#include <QMutex>
#include <QSet>
#include <QThreadPool>
#include <QWaitCondition>

#include "util/fifo.h"

// The max engine workers that can be expected to run within a callback
// (e.g. the max that we will schedule). Must be a power of 2.
#define MAX_ENGINE_WORKERS 32
// The max number of threads that EngineWorkers will be scheduled on. TODO(XXX)
// this should be dynamically chosen by the user, since it will vary depending
// on the machine resources available.
#define ENGINE_WORKER_THREAD_COUNT 4

class EngineWorker;

class EngineWorkerScheduler : public QThread {
    Q_OBJECT
  public:
    EngineWorkerScheduler(QObject* pParent=NULL);
    virtual ~EngineWorkerScheduler();

    void bindWorker(EngineWorker* pWorker);
    void runWorkers();

  protected:
    void run();

  private slots:
    void workerReady(EngineWorker* worker);
    void workerStarted(EngineWorker* worker);
    void workerFinished(EngineWorker* worker);

  private:
    FIFO<EngineWorker*> m_scheduleFIFO;
    QThreadPool m_workerThreadPool;
    QWaitCondition m_waitCondition;
    QMutex m_mutex;
    QSet<EngineWorker*> m_activeWorkers;
    volatile bool m_bQuit;
};

#endif /* ENGINEWORKERSCHEDULER_H */