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
|
#include <QCoreApplication>
#include <QFile>
#include "qcorotask.h"
#include "qcorotimer.h"
#include "qcoroiodevice.h"
using namespace std::chrono_literals;
// We could use std::stop_token, but it is not supported by AppleClang
struct Stop {
public:
void requestStop() {
mShouldStop = true;
}
bool stopRequested() const {
return mShouldStop;
}
private:
bool mShouldStop = false;
};
auto backgroundTask(const Stop &stop) -> QCoro::Task<> {
qDebug() << "Task: Background task started, waiting for event loop";
co_await QCoro::sleepFor(0ms);
qDebug() << "Task: Event loop is running";
QFile file(QStringLiteral("/dev/stdin"));
bool openResult = file.open(QIODevice::ReadOnly | QIODevice::Unbuffered);
Q_UNUSED(openResult);
while (!stop.stopRequested()) {
qDebug() << "Task: Waiting for input...";
const auto result = co_await qCoro(file).readLine(1024, 5s);
if (!result.isEmpty()) {
qDebug() << "Task: Read line:" << result;
} else {
qDebug() << "Task: Timeout!";
}
}
qDebug() << "Task: Backround task stopped";
}
int main(int argc, char **argv)
{
QCoreApplication app(argc, argv);
Stop stop;
auto bgTask = backgroundTask(stop);
QObject::connect(&app, &QCoreApplication::aboutToQuit, [&stop] {
qDebug() << "App: Requesting background task to stop";
stop.requestStop();
});
QTimer::singleShot(500ms, &app, []() {
qDebug() << "App: Stopping application";
QCoreApplication::instance()->quit();
});
// Run the app
qDebug() << "App: Starting application event loop";
const auto result = app.exec();
qDebug() << "App: Application event loop stopped";
// Wait for the background task to complete
qDebug() << "App: Waiting for background task to complete";
QCoro::waitFor(bgTask);
qDebug() << "App: Background task completed";
return result;
}
|
