c++ - 将 lambda 推送到 C++ STL 队列导致段错误

Question

我想将 lambda 推送到队列中。这个 lambda 将被弹出并执行到另一个线程中。当前线程将等待直到执行 lambda 并返回一些结果:

void * EglThread::execute(const std::function<void * ()> f) {
    std::condition_variable lambdaExecutedCond;
    void * out;
    bool exceptionFlag = false;
    std::exception exception;

    std::unique_lock<std::mutex> lk(this->mutex);
    this->queue.push([&]() -> void {
        std::unique_lock<std::mutex> __unused lock(this->mutex);
        lambdaExecutedCond.notify_one();

        try {
            out = f();
        } catch (const std::exception & e) {
            exceptionFlag = true;
            exception = e;
        }
    });
    this->cond.notify_all();
    lambdaExecutedCond.wait(lk);

    if (exceptionFlag) {
        throw exception;
    } else {
        return out;
    }
}

void EglThread::run() {
    while (true) {
        std::unique_lock<std::mutex> lk(this->mutex);
        if (this->queue.empty()) {
            if (this->flagShutdown) {
                break;
            } else {
                this->cond.wait(lk);
            }
        } else {
            this->queue.front()();
            this->queue.pop();
        }
    }
}

但是我在 push 操作期间遇到了 Segmentation fault 错误。日志看起来像:

EglThread::execute().

Queue pushing...

Segmentation fault

我不知道哪里出了问题。queue 对象声明为类成员，没有明确调用其构造函数。就像这样:

std::queue<std::function<void ()>> queue;

Answer 1

看例子(简化):

Log<ANDROID_LOG_INFO>("Queue pushing...\n");
this->queue.push([&]() -> void { /*...*/ } );
Log<ANDROID_LOG_INFO>("Queue pushed\n");

我们可以看到问题出在queue.push部分。这是您应该关注的。

所以可能的原因是:

1. queue 初始化不正确，
2. 在创建 lambda“对象”期间，可能会复制一些数据，这会导致此段错误。

出于第一个原因，我做了一个重复您的代码的最小示例:不同之处在于我将队列放入函数中。

void execute( const std::function<void* ()> f )
{
    std::queue<std::function<void* ()>> queue;

    queue.push( [ & ]() -> void*
    {
        return f();
    } );
}

int main()
{
    execute( []() -> void*
    {
        return nullptr;
    } );
}

这没问题。但这是单线程的!需要您提供更多信息来解释这些功能的执行方式/时间。尤其是竞争条件。

仅仅因为您使用了互斥锁，并不意味着您就那么安全。

第二个原因更难追踪。

为了调试，在 lambda 内部，我会一次注释掉每一行，看看这是否有助于克服段错误。这样我们就可以更容易地找到原因。