从主线程中删除 C++ 多线程纹理加载器工作项

Question

我有一个纹理加载线程，它通过并发队列从主线程接收加载纹理的请求。

纹理加载器请求是一个简单的结构，带有一个指向将接收纹理的对象的原始指针：

struct TextureLoaderRequest
{
    std::string mFilename;
    ContentViewer *mContentViewer;
};

ContentViewer 中包含的实际纹理对象受互斥体和一些原子布尔值（也包含在 ContentViewer 中）的保护：

std::atomic<bool>               mIsLoaded;
std::atomic<bool>               mIsVisible;
std::mutex                      mImageMutex;

那么纹理访问例程如下：

void ContentViewer::setTexture(ci::gl::TextureRef texture)
{
    std::lock_guard<std::mutex> guard(mImageMutex);
    mImage = texture;
}

ci::gl::TextureRef ContentViewer::getTexture()
{
    std::lock_guard<std::mutex> guard(mImageMutex);
    if (mIsVisible)
    {
        if (mImage != nullptr)
        {
            mIsLoaded = true;
            return mImage;
        }
        mIsLoaded = false;
    }
    return nullptr;
}

纹理加载器一次可能会从主线程接收多个纹理加载请求，然后通过队列加载并将纹理分配给纹理加载请求消息中指向的内容查看器。

我遇到的问题是，当主线程“删除”内容查看器时，纹理加载线程的队列中可能有一个未完成的请求，当它开始处理它时，内容查看器已被删除然后程序崩溃了。

我不确定如何删除纹理线程工作队列中的未完成的纹理加载请求。我不能让主线程等待为内容查看器加载相关纹理，但是，实现这一点的最佳实践策略是什么？

谢谢 - 铺设

Answer 1

好的，恕我直言，有两种选择：

1. 您等待对特定对象的所有请求都完成，然后再删除它。
2. 在执行任何计划的操作之前检查对象是否仍然存在。

我对您的应用程序没有足够的了解：队列是如何实现的以及为什么以及何时安排请求，因此我无法就此提供反馈。

Answer 2

我发现我需要从 std::mutex 受保护的向量中构造一个取消列表。当主线程想要退出时，它只需在向量中添加一个条目并继续。纹理加载线程有额外的负担检查每个接收到的纹理请求的列表，但操作不在关键路径上。

我仍然对替代方案/建议感兴趣。

线程的小轮廓如下：

void textureLoaderThreadFn()
{
    log("texture loader thread started");

    while (!mShouldQuit)
    {
        // Wait for texture loader request
        TextureLoaderRequest *textureLoaderRequest = nullptr;
        mTextureRequests->popBack(&textureLoaderRequest);

        // it is possible popBack didnt modify textureLoaderRequest (eg. when cancelled on exit)
        if (textureLoaderRequest != nullptr)
        {
            std::lock_guard<std::mutex> lk(mCancellationListMutex);

            if (std::find(mCancellationList.begin(), mCancellationList.end(), textureLoaderRequest->mFilename) != mCancellationList.end())
            {
                // Cancelled

                // we must reset the isLoading that was set by the main thread,
                // so that the request to load the texture can get put back if need be
                textureLoaderRequest->mContentViewer->mIsLoading = false;

                // remove from cancellation list
                mCancellationList.erase(std::remove(mCancellationList.begin(), mCancellationList.end(), textureLoaderRequest->mFilename), mCancellationList.end());
            }
            else
            {
                // Not cancelled
                <SERVICE TEXTURE REQUEST>
            }

            // dont need this anymore
            delete textureLoaderRequest;
        }
    }
    log("texture loader thread stopped");

    // Empty the queue    
    int count = 0;
    TextureLoaderRequest *textureLoaderRequest = nullptr;
    while (mTextureRequests->tryPopBack(&textureLoaderRequest))
    {
        if (textureLoaderRequest != nullptr)
            delete textureLoaderRequest;
        count++;
    }
    log("texture loader thread purged " + std::to_string(count) + " outstanding texture load requests");
}

Answer 3

我建议您在内容查看器中添加一个状态标志来区分 3 种状态；预定着色，被着色和未预定着色。 仅当内容查看器的状态为已安排着色或未安排着色时，主线程才应删除内容查看器。

纹理工作线程将状态更改为上色，一旦上色，就将其设置为上色。

状态的改变和状态是否可以删除的检查应该始终在同一个互斥锁范围内;您可以在内容查看器中将标志设为私有并使用两个公共方法 1)void change_status(status) 和 2)bool can_delete()。

这两个函数都应该从获取相同的互斥锁开始。 1) 用于主线程和纹理工作线程中的不同转换，2) 由主线程在删除内容查看器之前使用，仅当状态未着色时才返回 true。

在纹理工作线程中，在退出之前，您可以删除最后一个着色内容，以防主线程没有删除它（因为它可能处于着色状态）。