QtConcurrent::map分割故障

Question

当我试图使用QtConcurrent：：map实现"parallel“时：

QFuture<void> parForAsync(size_t n, std::function<void (size_t)> Op)
{

    size_t nThreads =
            static_cast<size_t>(QThreadPool::globalInstance()->maxThreadCount());
    size_t nn = n/nThreads + 1;

    using Sequence = QVector<std::function<void()>>;
    Sequence vFuns;

    for(size_t i = 0; i < n; i+=nn)
    {
        size_t firstIdx = i,
                lastIdx = i + nn > n ? n : i + nn;

        vFuns.push_back([=]()->void
        {
            for(size_t i = firstIdx; i < lastIdx; ++i)
            {
                Op(i);
            }
        });
    }
    return QtConcurrent::map<Sequence>    //<-Segmentation fault!
            (vFuns, [](std::function<void()> f)
    {
        f();
    });
}

我在这个地方有分割错误：

template<typename _Res, typename... _ArgTypes>
    function<_Res(_ArgTypes...)>::
    function(const function& __x)
    : _Function_base()
    {
      if (static_cast<bool>(__x))
    {
      __x._M_manager(_M_functor, __x._M_functor, __clone_functor); //<-Segmentation fault!
      _M_invoker = __x._M_invoker;
      _M_manager = __x._M_manager;
    }
    }

为什么会发生这种情况？似乎std：：函数已经通过了检查。我怎样才能使这个代码工作呢？

提前感谢！

Answer 1

我不能重现你的案例，但我可以给你一些例子来说明问题。

QFuture<void> test ()
{   
    QVector<int> v; // LOCAL VARIABLE IN SCOPE OF test FUNCTION

    // preparing v vector

    QFuture<void> f = QtConcurrent::map(v,someFunction); // returns immediately
    return f;
}

1 QtConcurrent::map通过引用而不是复制来获取v。

2 QtConcurrent::map立即返回。

3因此，当test函数结束时，map启动的并行操作使用v向量删除，因为它是test函数中的局部变量。

您可以将waitForFinished用于QFuture，但是您的函数没有意义，因为它一直阻塞直到并行任务结束。