Task.h++

Go to the documentation of this file.

#ifndef __libquark_util_Task_hxx
#define __libquark_util_Task_hxx

#include <QAtomicInt>
#include <QObject>

#include <quark/Quark.h++>

namespace quark {
namespace util {

class TaskProcessor;

class LIBQUARK_API Task : public QObject
{
  Q_OBJECT;

  friend class TaskProcessor;

  public:

  virtual ~Task();

  inline int id() const
  { return(_id); }

  inline bool isRunning() const
  { return(_running); }

  inline bool isCancelling() const
  { return(_cancelling); }

  inline bool isCancelled() const
  { return(_cancelled); }

  inline bool isFailed() const
  { return(_failed); }

  inline bool isBackground() const
  { return(_background); }

  inline QString error() const
  { return(_error); }

  void setTimeout(int seconds);

  qint64 executionTime() const;

  static const int DEFAULT_TIMEOUT;

 signals:

  void statusUpdated(const QString& status);

  void finished();

  void cancelled();

 protected:

  Task(bool background = false);

  virtual void execute() = 0;

  virtual bool cancel();

  void setCancelled();

  void fail(QString error = QString());

  void updateStatus(const QString& text);

 private:

  void process();
  bool tryCancel();
  void notifyFinished();
  void notifyCancelled();
  bool isTimedOut(const qint64 &now) const;

  inline void setRunning(bool running)
  { _running = running; }

  int _id;
  bool _background;
  bool _running;
  bool _cancelling;
  bool _cancelled;
  bool _failed;
  qint64 _startTime;
  qint64 _endTime;
  int _timeout;
  QString _error;

  static QAtomicInt _idCounter;

  Q_DISABLE_COPY(Task);
};

} // namespace util
} // namespace quark

#endif // __libquark_util_Task_hxx