如何保证API在异步API中调用它的回调之前返回（c ++）

Question

我开发了一个具有异步 API 的库。 其中一个 API，当它被调用时，它会创建一个任务，将其推送到任务线程并返回其任务 ID。 任务完成后，任务线程通过回调函数将结果通知给调用者。

顺序如下

来电者

C.1。调用者调用 API

C.2。库。创建任务并将其推送到任务线程的队列中

C.3。库。通过调用 condition_variable 的 notify_all 来唤醒任务线程

C.4。此时可以发生上下文切换，该线程将被挂起

C.6。此线程恢复后，Lib.返回任务ID

任务线程

T.1。任务线程执行任务。

T.2。任务完成后，任务线程通过回调将结果通知给调用者

问题

调用者通过任务ID检查回调函数的结果数据，但偶尔在API返回之前调用回调，调用者无法检查结果。

问题

我想完美地保证 API 在调用其回调之前返回任务 ID。 我能做什么？

我在 API 的主体中使用 lock_guard 来防止回调被调用，它大大降低了重现此问题的可能性。

但是因为lock_guard在API返回之前解锁了mutex，如果在mutex解锁之后发生context-switch，在API返回之前，这个问题很少会重现。

我也想阻止这种情况。

摘要代码

long AcbCore::setState(long appState, long playState)   // API
{
    StateTask* task = (StateTask*) createTask(TaskType::PLAYER_STATE_CHANGE, &isAppSwitchingStateFlag, appState);

    std::lock_guard<std::mutex> lockGd (*task->getEventMutex());
    pushTask(task);      // at this position, context switch can occur by condTaskThread_.notify_all() of resumeLoop()

    return taskId;
}

void AcbCore::pushTask(Task* task)
{
    mtxTaskQueue_.lock();
    queueTask_.push_back(task);
    mtxTaskQueue_.unlock();

    resumeLoop();
}

void AcbCore::resumeLoop()
{
    mtxTaskThread_.lock();
    mtxTaskThread_.unlock();
    condTaskThread_.notify_all();
}

bool AcbCore::suspendLoop()
{
    bool isTimeout = false;
    if (ingTask_ != NULL) {
        isTimeout = (condTaskThread_.wait_for(lockTaskThread_, std::chrono::seconds(AWAKE_TASK_THREAD_TIMEOUT)) == std::cv_status::timeout);
    } else {
        condTaskThread_.wait(lockTaskThread_);
    }

    return isTimeout;
}

void AcbCore::taskLoop()  // loop of Task Thread
{
    Task* task = NULL;
    Action* action = NULL;
    while (isInitialized_) {
        while (popTask(task)) {
            if (task->isCompleted()) {
                fireEvent(task);
            } else {
                doNextTask(task);
            }
        }
        if (suspendLoop()) {    //  if awaked by timeout
            cancelTask(ingTask_, true);
        }
    }
}

void AcbCore::fireEvent(Task* task, bool bDelete)
{
    std::string errorInfo = task->getErrorInfo();

    task->waitToUnlockEvent();
    // eventHandler_ : callback set by caller when Acb is initialized
    eventHandler_(task->getTaskId(), task->getEventType(), appState_.now_, playState_.now_, errorInfo.c_str());

    if (bDelete) {
        deleteTask(task);
    }
}

Answer 1

从根本上说，你无法解决这个问题。让我们假设初始线程恰好在代码的最后一条指令之后，但在调用者获取任务 ID 之前暂停。您根本无法确定调用者何时以允许回调发生的方式存储了任务 ID。

相反，当客户端有一个未完成的异步函数调用时，他应该缓存未知的任务 ID。