ConcurrentControlNetReader.h

#ifndef ConcurrentControlNetReader_h
#define ConcurrentControlNetReader_h

 
/* SPDX-License-Identifier: CC0-1.0 */
#include <functional>
 
#include <QObject>
#include <QPair>
#include <QPointer>
#include <QString>
#include <QStringList>
 
#include "ProgressBar.h"
 
template<typename A> class QAtomicPointer;
template<typename A> class QFutureWatcher;
 
namespace Isis {
  class Control;
  class FileName;
  class Progress;
  class ProgressBar;
 

  class ConcurrentControlNetReader : public QObject {
      Q_OBJECT
 
    public:
      ConcurrentControlNetReader();
      ~ConcurrentControlNetReader();
      void read(QString filename);
      void read(QStringList filenames);
      ProgressBar *progressBar();
 
    signals:
      void networksReady(QList<Control *>);
 
    private:
      void nullify();
      void start();
 
    private slots:
      void updateProgressValue();
      void mappedFinished();
 
    private:
      void initProgress();
 
    private:
      QFutureWatcher<Control *> * m_watcher;
      QStringList m_backlog;
      bool m_mappedRunning;
      QList<Progress *> m_progress;
      QPointer<ProgressBar> m_progressBar;
      QPointer<QTimer> m_progressUpdateTimer;

      class FileNameToControlFunctor : public std::function<
          Control *(const QPair<FileName, Progress *> &)> {
        public:
          FileNameToControlFunctor(QThread *);
          FileNameToControlFunctor(const FileNameToControlFunctor &);
          ~FileNameToControlFunctor();
          Control * operator()(const QPair<FileName, Progress *> &) const;
          FileNameToControlFunctor & operator=(const FileNameToControlFunctor &);
 
        private:
          QThread *m_targetThread;
      };
  };
}
 
#endif