在使用 QThreadPool 提交任務后，如果你需要知道任務何時完成，并且需要使用任務的執行結果，可以通過以下幾種方式來實現：

1. 使用信號和槽

QRunnable 提供了一個 finished() 信號，當任務執行完成后會發出。你可以在任務完成后通過信號和槽機制通知主線程。

示例代碼

#include <QCoreApplication>
#include <QThreadPool>
#include <QRunnable>
#include <QDebug>
#include <QThread>class Worker : public QRunnable {
public:Worker() {// 連接 finished 信號到自定義槽connect(this, &Worker::finished, this, &Worker::onFinished);}void run() override {qDebug() << "Worker running in thread" << QThread::currentThreadId();// 模擬耗時任務QThread::sleep(3);qDebug() << "Worker finished";emit finished(); // 發出任務完成信號}private slots:void onFinished() {qDebug() << "Worker finished in thread" << QThread::currentThreadId();// 在這里可以處理任務完成后的邏輯}
};int main(int argc, char *argv[]) {QCoreApplication app(argc, argv);// 獲取全局線程池QThreadPool* globalThreadPool = QThreadPool::globalInstance();// 創建一個任務Worker* worker = new Worker();// 將任務添加到全局線程池qDebug() << "Starting worker in main thread" << QThread::currentThreadId();globalThreadPool->start(worker);// 主線程繼續運行qDebug() << "Main thread continues running immediately";QThread::sleep(1); // 等待一段時間，觀察輸出qDebug() << "Main thread still running";return app.exec();
}

輸出示例

Starting worker in main thread 0x1234
Main thread continues running immediately
Main thread still running
Worker running in thread 0x5678
Worker finished
Worker finished in thread 0x5678

2. 使用 QFuture 和 QtConcurrent::run

如果你需要更靈活的異步任務管理，可以使用 QtConcurrent::run，它會返回一個 QFuture 對象，你可以通過它來檢查任務的狀態或獲取任務的返回值。

示例代碼

#include <QCoreApplication>
#include <QtConcurrent>
#include <QDebug>
#include <QThread>
#include <QFuture>
#include <QFutureWatcher>int workerFunction() {qDebug() << "Worker running in thread" << QThread::currentThreadId();// 模擬耗時任務QThread::sleep(3);qDebug() << "Worker finished";return 42; // 返回結果
}int main(int argc, char *argv[]) {QCoreApplication app(argc, argv);// 使用 QtConcurrent::run 提交任務QFuture<int> future = QtConcurrent::run(workerFunction);// 主線程繼續運行qDebug() << "Main thread continues running immediately";QThread::sleep(1); // 等待一段時間，觀察輸出qDebug() << "Main thread still running";// 等待任務完成并獲取結果qDebug() << "Waiting for worker to finish...";int result = future.result(); // 阻塞主線程，直到任務完成qDebug() << "Worker result:" << result;return app.exec();
}

輸出示例

Main thread continues running immediately
Main thread still running
Worker running in thread 0x5678
Worker finished
Waiting for worker to finish...
Worker result: 42

3. 使用 QThreadPool::waitForDone()

如果你需要等待所有任務完成，可以使用 QThreadPool::waitForDone() 方法。這個方法會阻塞當前線程，直到線程池中的所有任務都完成。

示例代碼

#include <QCoreApplication>
#include <QThreadPool>
#include <QRunnable>
#include <QDebug>
#include <QThread>class Worker : public QRunnable {
public:void run() override {qDebug() << "Worker running in thread" << QThread::currentThreadId();// 模擬耗時任務QThread::sleep(3);qDebug() << "Worker finished";}
};int main(int argc, char *argv[]) {QCoreApplication app(argc, argv);// 獲取全局線程池QThreadPool* globalThreadPool = QThreadPool::globalInstance();// 創建一個任務Worker* worker = new Worker();// 將任務添加到全局線程池qDebug() << "Starting worker in main thread" << QThread::currentThreadId();globalThreadPool->start(worker);// 主線程繼續運行qDebug() << "Main thread continues running immediately";QThread::sleep(1); // 等待一段時間，觀察輸出qDebug() << "Main thread still running";// 等待所有任務完成qDebug() << "Waiting for all tasks to finish...";globalThreadPool->waitForDone();qDebug() << "All tasks finished";return app.exec();
}

輸出示例

Starting worker in main thread 0x1234
Main thread continues running immediately
Main thread still running
Worker running in thread 0x5678
Worker finished
Waiting for all tasks to finish...
All tasks finished

總結

• 信號和槽：通過 QRunnable::finished 信號通知任務完成。
• QFuture 和 QtConcurrent::run：提供更靈活的異步任務管理，可以獲取任務的返回值。
• QThreadPool::waitForDone：等待線程池中的所有任務完成，但會阻塞當前線程。

根據你的需求選擇合適的方法。如果你需要任務的返回值，建議使用 QtConcurrent::run 和 QFuture。

---

QtConcurrent::run 和直接使用 QThread 在功能和使用方式上有顯著的區別。以下是它們的主要區別：

1. 使用方式

• QtConcurrent::run：

  • 更簡單：QtConcurrent::run 是一個高級接口，用于簡化異步任務的提交和管理。它返回一個 QFuture 對象，可以用來檢查任務的狀態或獲取任務的返回值。
  • 無需手動管理線程：你只需要提供一個函數或 lambda 表達式，QtConcurrent::run 會自動將任務提交到線程池中執行，無需手動創建和管理 QThread。
  • 支持返回值：QFuture 可以存儲任務的返回值，方便在任務完成后獲取結果。

• QThread：

  • 更靈活：QThread 是一個低級接口，提供了對線程的細粒度控制。你可以創建自己的線程類，管理線程的啟動、停止和同步。
  • 需要手動管理線程：你需要手動創建線程，連接信號和槽，管理線程的生命周期。
  • 不直接支持返回值：線程的執行結果需要通過信號和槽或其他機制傳遞回主線程。

2. 線程管理

• QtConcurrent::run：

  • 使用線程池：QtConcurrent::run 內部使用 QThreadPool 來管理線程。任務會被提交到全局線程池中，由線程池負責分配線程。這種方式可以減少線程創建和銷毀的開銷，提高性能。
  • 自動管理線程生命周期：任務完成后，線程會自動返回線程池，無需手動管理。

• QThread：

  • 手動管理線程：你需要手動創建和啟動線程，并在任務完成后手動停止線程。
  • 線程生命周期：線程的生命周期由你控制，需要確保線程在任務完成后正確退出。

3. 任務狀態和結果

• QtConcurrent::run：

  • QFuture 提供狀態檢查：QFuture 提供了多種方法來檢查任務的狀態，例如：
    • isFinished()：檢查任務是否完成。
    • isRunning()：檢查任務是否正在運行。
    • result()：獲取任務的返回值。
  • 支持異步操作：QFuture 可以與 QFutureWatcher 配合使用，通過信號和槽機制在任務完成時通知主線程。

• QThread：

  • 手動檢查狀態：你需要通過信號和槽機制或手動檢查線程的狀態。
  • 不直接支持返回值：線程的執行結果需要通過信號和槽或其他機制傳遞回主線程。

4. 適用場景

• QtConcurrent::run：

  • 簡單任務：適用于簡單的異步任務，特別是那些不需要復雜線程管理的場景。
  • 任務結果處理：當你需要獲取任務的返回值時，QFuture 提供了方便的接口。

• QThread：

  • 復雜任務：適用于需要更細粒度控制線程的復雜任務。
  • 長時間運行的任務：適用于需要長時間運行的后臺任務，例如網絡通信、文件處理等。

示例對比

使用 QtConcurrent::run

#include <QCoreApplication>
#include <QtConcurrent>
#include <QDebug>
#include <QThread>int workerFunction() {qDebug() << "Worker running in thread" << QThread::currentThreadId();QThread::sleep(3);qDebug() << "Worker finished";return 42; // 返回結果
}int main(int argc, char *argv[]) {QCoreApplication app(argc, argv);// 提交任務QFuture<int> future = QtConcurrent::run(workerFunction);// 主線程繼續運行qDebug() << "Main thread continues running immediately";QThread::sleep(1);// 等待任務完成并獲取結果qDebug() << "Waiting for worker to finish...";int result = future.result();qDebug() << "Worker result:" << result;return app.exec();
}

使用 QThread

#include <QCoreApplication>
#include <QThread>
#include <QDebug>
#include <QMutex>
#include <QWaitCondition>class Worker : public QObject {Q_OBJECT
public:Worker() : result(0), finished(false) {}void run() {qDebug() << "Worker running in thread" << QThread::currentThreadId();QThread::sleep(3);result = 42; // 設置結果finished = true; // 標記任務完成condition.wakeOne(); // 通知主線程}int getResult() const { return result; }bool isFinished() const { return finished; }signals:void finished();private:mutable QMutex mutex;QWaitCondition condition;int result;bool finished;
};int main(int argc, char *argv[]) {QCoreApplication app(argc, argv);Worker worker;QThread thread;worker.moveToThread(&thread);QObject::connect(&thread, &QThread::started, &worker, &Worker::run);thread.start();qDebug() << "Main thread continues running immediately";QThread::sleep(1);// 等待任務完成qDebug() << "Waiting for worker to finish...";QMutexLocker locker(&worker.mutex);while (!worker.isFinished()) {worker.condition.wait(&locker);}int result = worker.getResult();qDebug() << "Worker result:" << result;thread.quit();thread.wait();return app.exec();
}

總結

• QtConcurrent::run：

  • 優點：簡單易用，自動管理線程，支持返回值。
  • 缺點：功能相對有限，適合簡單任務。
  • 適用場景：適合簡單的異步任務，特別是需要獲取任務結果的場景。

• QThread：

  • 優點：功能強大，支持復雜的線程管理。
  • 缺點：使用復雜，需要手動管理線程。
  • 適用場景：適合需要細粒度控制線程的復雜任務。

根據你的需求選擇合適的方式。如果你的任務簡單且需要返回值，推薦使用 QtConcurrent::run。如果你的任務復雜且需要更細粒度的線程管理，推薦使用 QThread。

---

在 Qt 中，QFuture 是一個線程安全的對象，用于表示異步操作的結果。當你將 QFuture 作為值傳遞給其他函數時，實際上傳遞的是一個輕量級的“未來”對象的副本。這個副本與原始的 QFuture 對象共享底層的異步操作狀態。

關鍵點

• 共享狀態：盡管 QFuture 是按值傳遞的，但它內部維護的是一個共享的狀態。這意味著，無論你傳遞了多少個副本，它們都會指向同一個底層的異步操作狀態。
• 線程安全：QFuture 的狀態是線程安全的，因此你可以在多個線程中安全地訪問和修改它的狀態。

示例

假設你有以下代碼：

void MachineFileBrowser::handleSingleClick(const QModelIndex &index)
{if (index.isValid() && lastClickedIndex == index){QString path = model->getFilePath(index);fileloadFuture = QtConcurrent::run([this, path]() {MachineTree &tempTree = currentTemplate->getMachineTree();tempTree = MachineTree::parseFromTarXmlFile(path);  // 解析機器樹數據});emit itemReClicked(index, fileloadFuture);} else{lastClickedIndex = index;}
}

在 itemReClicked 信號的槽函數中，你可以這樣處理：

void SomeClass::handleItemReClicked(const QModelIndex &index, QFuture<void> future)
{// 檢查任務是否完成if (future.isFinished()){qDebug() << "Task is finished";}else{qDebug() << "Task is still running";}
}

關鍵點解釋

1. fileloadFuture 的狀態：

   • fileloadFuture 是一個 QFuture<void> 對象，它表示一個異步操作的未來結果。
   • 當你將 fileloadFuture 傳遞給 itemReClicked 信號時，傳遞的是一個副本，但這個副本與原始的 fileloadFuture 共享底層的狀態。

2. 狀態同步：

   • 無論你在哪個地方訪問 fileloadFuture，它的狀態（例如 isFinished()）始終是同步的。這是因為 QFuture 內部使用了共享的狀態機制。
   • 這意味著，即使你在多個地方持有 fileloadFuture 的副本，它們的狀態始終是一致的。

示例代碼

假設你有一個槽函數 handleItemReClicked，它接收 fileloadFuture 的副本：

void SomeClass::handleItemReClicked(const QModelIndex &index, QFuture<void> future)
{// 檢查任務是否完成if (future.isFinished()){qDebug() << "Task is finished";}else{qDebug() << "Task is still running";}
}

在 handleSingleClick 中，你發射了 itemReClicked 信號：

emit itemReClicked(index, fileloadFuture);

在槽函數中，你可以通過 future.isFinished() 檢查任務是否完成。無論任務是否完成，future.isFinished() 的結果始終是正確的，因為 QFuture 的狀態是共享的。

總結

• QFuture 的狀態是共享的：即使你將 QFuture 作為值傳遞，它的狀態仍然是共享的。
• 線程安全：QFuture 的狀態是線程安全的，你可以在多個線程中安全地訪問和修改它的狀態。
• 狀態同步：無論你在哪個地方訪問 QFuture，它的狀態始終是一致的。

因此，即使 fileloadFuture 是按值傳遞的，你仍然可以在其他函數中通過 isFinished() 檢查任務的狀態，并且結果始終是正確的。