TaskProcessor.h++

Go to the documentation of this file.

#ifndef __libquark_util_TaskProcessor_hxx
#define __libquark_util_TaskProcessor_hxx

#include <QEvent>
#include <QMap>
#include <QMutex>
#include <QThread>
#include <QTimer>

#include <quark/Quark.h++>

namespace quark {
namespace util {

class Task;

class LIBQUARK_API TaskProcessor : public QThread
{
  Q_OBJECT;

  public:

  TaskProcessor(QObject *parent = NULL);

  virtual ~TaskProcessor();

  int addTask(Task *task);

  bool cancelTask(int taskId);

  bool stop();

  signals:

  void busyStateChanged(bool busy);

  protected:

  virtual void customEvent(QEvent *event);
  private slots:

  void taskFinished();
  void checkForTimeouts();

  private:

  void cleanUpTask(Task *task);

  QMap<int, Task *> _tasks;
  int _activeTasks;
  QTimer _timer;
  QMutex _lock;
};

} // namespace util
} // namespace quark

#endif // __libquark_util_TaskProcessor_hxx