/home/maxime/Projets/Mixxx/1.10/mixxx/src/analyserqueue.h

Go to the documentation of this file.

#ifndef ANALYSERQUEUE_H
#define ANALYSERQUEUE_H

#include <QList>
#include <QThread>
#include <QQueue>
#include <QWaitCondition>

#include "configobject.h"
#include "analyser.h"
#include "trackinfoobject.h"

class SoundSourceProxy;

class AnalyserQueue : public QThread {
    Q_OBJECT

  public:
    AnalyserQueue();
    virtual ~AnalyserQueue();
    void stop();
    int numQueuedTracks();

    static AnalyserQueue* createDefaultAnalyserQueue(ConfigObject<ConfigValue> *_config);
    static AnalyserQueue* createPrepareViewAnalyserQueue(ConfigObject<ConfigValue> *_config);
    static AnalyserQueue* createAnalyserQueue(QList<Analyser*> analysers);

  public slots:
    void queueAnalyseTrack(TrackPointer tio);

  signals:
    void trackProgress(TrackPointer pTrack,int progress);
    void trackFinished(TrackPointer pTrack);
    void queueEmpty();

  protected:
    void run();

  private:
    void addAnalyser(Analyser* an);

    QList<Analyser*> m_aq;

    TrackPointer dequeueNextBlocking();
    void doAnalysis(TrackPointer tio, SoundSourceProxy *pSoundSource);

    bool m_exit;

    // The processing queue and associated mutex
    QQueue<TrackPointer> m_tioq;
    QMutex m_qm;
    QWaitCondition m_qwait;
};

#endif