blob: 7a2dd4357cb59af62a1514f93aaef27031193cee (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
// Copyright (C) 2021 The Qt Company Ltd.
// Copyright (C) 2019 Luxoft Sweden AB
// Copyright (C) 2018 Pelagicore AG
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR GPL-3.0-only
#pragma once
#include <QThread>
#include <QMutex>
#include <QtAppManCommon/error.h>
QT_BEGIN_NAMESPACE_AM
class AsynchronousTask : public QThread
{
Q_OBJECT
public:
enum TaskState
{
Invalid,
Queued,
Executing,
Failed,
Finished,
// installation task only
AwaitingAcknowledge,
Installing,
CleaningUp
};
Q_ENUM(TaskState)
AsynchronousTask(QObject *parent = nullptr);
QString id() const;
TaskState state() const;
void setState(TaskState state);
bool hasFailed() const;
Error errorCode() const;
QString errorString() const;
virtual bool cancel();
bool forceCancel(); // will always work in Queued state
QString packageId() const; // convenience
virtual bool preExecute();
virtual bool postExecute();
signals:
void stateChanged(QT_PREPEND_NAMESPACE_AM(AsynchronousTask::TaskState) newState);
void progress(qreal p);
protected:
void setError(Error errorCode, const QString &errorString);
virtual void execute() = 0;
void run() override final;
protected:
QMutex m_mutex;
QString m_id;
QString m_packageId;
TaskState m_state = Queued;
Error m_errorCode = Error::None;
QString m_errorString;
};
QT_END_NAMESPACE_AM
|