@@ -69,7 +69,7 @@ void ConcurrentTask::addTask(Task::Ptr task)
|
||||
void ConcurrentTask::executeTask()
|
||||
{
|
||||
for (auto i = 0; i < m_total_max_size; i++)
|
||||
executeNextSubTask();
|
||||
QMetaObject::invokeMethod(this, &ConcurrentTask::executeNextSubTask, Qt::QueuedConnection);
|
||||
}
|
||||
|
||||
bool ConcurrentTask::abort()
|
||||
@@ -127,7 +127,7 @@ void ConcurrentTask::executeNextSubTask()
|
||||
}
|
||||
return;
|
||||
}
|
||||
if (m_doing.count() > m_total_max_size) {
|
||||
if (m_doing.count() >= m_total_max_size) {
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user