taskscheduler.h

Go to the documentation of this file.

//#
//# Copyright (C) 2021-2025 QuasarApp.
//# Distributed under the lgplv3 software license, see the accompanying
//# Everyone is permitted to copy and distribute verbatim copies
//# of this license document, but changing it is not allowed.
//#
 
#ifndef TASKSCHEDULER_H
#define TASKSCHEDULER_H
 
#include "abstracttask.h"
 
#include <QHash>
#include <QMap>
#include <QSharedPointer>
#include <QTimer>
 
namespace QH {

class TaskScheduler: public QObject
{
    Q_OBJECT
public:
    TaskScheduler();
    ~TaskScheduler();

    bool shedule(const QSharedPointer<AbstractTask>& task);

    bool remove(const QSharedPointer<AbstractTask>& task);

    bool remove(int task);

    int taskCount() const;
 
signals:
    void sigPushWork(QSharedPointer<QH::AbstractTask> work);
 
private slots:
    void handleTimeOut();
 
private:
    int getTimeout(qint64 timeout);
 
 
    QMultiMap<quint64, int> _taskQueue;
    QHash<int, QSharedPointer<AbstractTask>> _taskPool;
    QTimer *_timer = nullptr;
};
}
#endif // TASKSCHEDULER_H