1

我目前正在使用 QThreadPool 来运行一些计算，但是我发现如果我将所有东西都扔到 QThreadPool 中，它实际上表现不佳并且似乎导致了一些崩溃问题。所以我的想法是一次只有几个线程传递到 QThreadPool 中。我想知道是否有人可以分享一些关于如何使用 QThreadPool 在一台 PC 上处理数千次计算的代码或示例。我写了如下的东西，但我觉得它目前给我造成了一些崩溃问题（A类继承自QRunnable）：

for(int i=0;i<1000;i++)
{
    Class* A = new Class();
    A->doSomeSetting(i);

    A->setAutoDelete(true);

    connect(A,SIGNAL(OutputProvider(int))
       ,this,SLOT(OutputListener(int)),Qt::DirectConnection);

    QThreadPool::globalInstance()->start(A);

    m_thread_count++;

    if(m_thread_count >0 && m_thread_count %m_maxThreadInPool == 0)
    {
        QThreadPool::globalInstance()->waitForDone();
    }
}
QThreadPool::globalInstance()->waitForDone();

和初始化设置：

m_maxThreadInPool = 4;
QThreadPool::globalInstance()->setMaxThreadCount(4);
m_thread_count = 0;
std::vector<int> output;

输出监听器：

void OutputListener(int output)
{
    output.push_back(output);
}

这是正确的做法还是有更好的方法？

此外，在设置最大线程数时，您可以输入的最大数量是您可以拥有的核心数吗？

我也在使用 Qt::DirectConnection（我使用 QueueConnection 时遇到了一些问题）。写入输出侦听器时会出现问题吗？

4

2 回答 2

2

Qt::DirectConnection 可能是个问题。如文档中所述，Queded 连接需要与线程一起使用。参见 QtConcurrent with QFuture 和 QFutureWatcher，这个类可能对你有所帮助

于 2014-03-27T11:27:32.493 回答
1 
m_thread_count++;

if(m_thread_count >0 && m_thread_count %m_maxThreadInPool == 0)
{
    QThreadPool::globalInstance()->waitForDone();
}

您正在等待每 4 个任务完成所有任务：删除所有对 waitForDone 的调用，然后您将看到改进并QueuedConnection再次工作

您可以添加比线程更多的任务额外的任务将等到其他任务之一完成

于 2014-03-27T11:27:43.147 回答