feat: implement concurrent task in a proper way

1 files changed, 12 insertions, 4 deletions

diff --git a/src/core/thread/Task.cpp b/src/core/thread/Task.cpp
index 937211cf..f3c6ae86 100644
--- a/src/core/thread/Task.cpp
+++ b/src/core/thread/Task.cpp
@@ -160,10 +160,18 @@ void GpgFrontend::Thread::Task::run() {
 
   if (thread() != QThread::currentThread()) {
     SPDLOG_DEBUG("task running thread is not object living thread");
-    // running in another thread, blocking until returned
-    if (!QMetaObject::invokeMethod(thread(), runnable_package,
-                                   Qt::BlockingQueuedConnection)) {
-      SPDLOG_ERROR("qt invoke method failed");
+    // if running sequently
+    if (sequency_) {
+      // running in another thread, blocking until returned
+      if (!QMetaObject::invokeMethod(thread(), runnable_package,
+                                     Qt::BlockingQueuedConnection)) {
+        SPDLOG_ERROR("qt invoke method failed");
+      }
+    } else {
+      // running in another thread, non-blocking
+      if (!QMetaObject::invokeMethod(thread(), runnable_package)) {
+        SPDLOG_ERROR("qt invoke method failed");
+      }
     }
   } else {
     if (!QMetaObject::invokeMethod(this, runnable_package)) {