Method scheduleBlockingTask

Engine/GenericSchedulerThreadWatcher.cpp:171–200

}

void
GenericWatcher::scheduleBlockingTask(int taskID,
                                     const GenericWatcherCallerArgsPtr& args)
{
    {
        QMutexLocker quitLocker(&_imp->mustQuitMutex);
        if (_imp->mustQuit) {
            return;
        }
    }

    {
        QMutexLocker(&_imp->tasksMutex);
        GenericWatcherPrivate::Task t;
        t.id = taskID;
        t.args = args;
        _imp->tasks.push_back(t);
    }

    if ( !isRunning() ) {
        start();
    } else {
        ///Wake up the thread with a start request
        QMutexLocker locker(&_imp->startRequestsMutex);
        if (_imp->startRequests <= 0) {
            ++_imp->startRequests;
        }
        _imp->startRequestsCond.wakeOne();
    }
}

void
GenericSchedulerThreadWatcher::handleBlockingTask(int taskID)