FindFilesThreadPoolManager.h

Go to the documentation of this file.

// Mantid Repository : https://github.com/mantidproject/mantid
//
// Copyright © 2018 ISIS Rutherford Appleton Laboratory UKRI,
//   NScD Oak Ridge National Laboratory, European Spallation Source,
//   Institut Laue - Langevin & CSNS, Institute of High Energy Physics, CAS
// SPDX - License - Identifier: GPL - 3.0 +
#pragma once
 
#include "MantidQtWidgets/Common/DllOption.h"
#include "MantidQtWidgets/Common/FindFilesWorker.h"
 
#include <QObject>
#include <QRunnable>
#include <QSharedPointer>
#include <QString>
#include <QThreadPool>
#include <functional>
#include <memory>
#include <string>
#include <vector>
 
namespace MantidQt {
namespace API {
 
class EXPORT_OPT_MANTIDQT_COMMON FindFilesThreadPoolManager : public QObject {
  Q_OBJECT
  using ThreadAllocator = std::function<FindFilesWorker *(const FindFilesSearchParameters &)>;
 
public:
  FindFilesThreadPoolManager();
  void setAllocator(ThreadAllocator allocator);
 
  void createWorker(const QObject *parent, const FindFilesSearchParameters &parameters);
  bool isSearchRunning() const;
  void waitForDone();
  static void destroyThreadPool();
 
signals:
  // Signal emitted to cancel any already running workers
  void disconnectWorkers();
 
private slots:
  // Handle when a search is finished
  void searchFinished();
 
private:
  const std::unique_ptr<QThreadPool> &poolInstance() const;
  void cancelWorker();
  void connectWorker(const QObject *parent, const FindFilesWorker *worker);
 
  ThreadAllocator m_workerAllocator;
  bool m_searchIsRunning;
};
 
} // namespace API
} // namespace MantidQt