modelupdatethreadworker.h

Go to the documentation of this file.

 
#ifndef MODELUPDATETHREADWORKER_H
#define MODELUPDATETHREADWORKER_H
 
#include "nodelistobject.h"
 
#include <peak/node_map/peak_node_map.hpp>
 
#include <QMutex>
#include <QObject>
#include <QStringList>
 
#include <unordered_map>
#include <vector>
#include <atomic>
 
class ModelUpdateThreadWorker : public QObject
{
    Q_OBJECT
public:
    enum class State
    {
        IDLE,
        BUSY,
        PAUSED,
        CANCELED
    };
 
    explicit ModelUpdateThreadWorker(QObject* parent = nullptr);
    ~ModelUpdateThreadWorker() override;
 
    State currentState();
 
    void setNodeMap(std::shared_ptr<peak::core::NodeMap> nodeMap);
    void setNodes(const std::vector<std::shared_ptr<peak::core::nodes::Node>>& nodes);
    void update();
    void pause();
    void resume();
 
public slots:
    void cancel();
    void nodeChanged(const std::shared_ptr<peak::core::nodes::Node>& changedNode);
    void unregisterAll();
 
signals:
    void updateList(int minIndex, int maxIndex, QVector<int> changedRoles);
    void updateRequest();
    void started();
    void finished();
 
private:
    std::shared_ptr<peak::core::NodeMap> m_nodeMap;
    QStringList m_nodeNames;
    std::vector<std::unique_ptr<NodeListObject>> m_objects;
    std::unordered_map<std::string, peak::core::nodes::Node::ChangedCallbackHandle>
        m_nodeChangedCallbackHandles;
    std::vector<std::string> m_changedNodes;
 
    std::atomic<State> m_state{State::IDLE};
 
    mutable QMutex mutex;
    void clear();
};
 
#endif // MODELUPDATETHREADWORKER_H