File indexing completed on 2025-01-19 04:52:02

0001 /*
0002     Copyright (c) 2017 Christian Mollekopf <mollekopf@kolabsys.com>
0003 
0004     This library is free software; you can redistribute it and/or modify it
0005     under the terms of the GNU Library General Public License as published by
0006     the Free Software Foundation; either version 2 of the License, or (at your
0007     option) any later version.
0008 
0009     This library is distributed in the hope that it will be useful, but WITHOUT
0010     ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
0011     FITNESS FOR A PARTICULAR PURPOSE.  See the GNU Library General Public
0012     License for more details.
0013 
0014     You should have received a copy of the GNU Library General Public License
0015     along with this library; see the file COPYING.LIB.  If not, write to the
0016     Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
0017     02110-1301, USA.
0018 */
0019 #pragma once
0020 
0021 #include <QtConcurrent/QtConcurrentRun>
0022 #include <QFuture>
0023 #include <QFutureWatcher>
0024 #include <QPointer>
0025 
0026 template<typename T>
0027 void asyncRun(QObject *object, std::function<T()> run, std::function<void(T)> continuation)
0028 {
0029     auto guard = QPointer<QObject>{object};
0030     auto future = QtConcurrent::run(run);
0031     auto watcher = new QFutureWatcher<T>;
0032     QObject::connect(watcher, &QFutureWatcher<T>::finished, watcher, [watcher, continuation, guard]() {
0033         if (guard) {
0034             continuation(watcher->future().result());
0035         }
0036         delete watcher;
0037     });
0038     watcher->setFuture(future);
0039 }
0040