c++ - 多线程函数重启模式/解决方案

Question

我有以下场景:

一个线程正在类 X 的方法 A 中迭代列表数据结构。该数据结构是一个缓存。在任何时候，我们都可以调用 X 类中的方法 B，说我们的缓存已过时。在那种情况下，如果我们当前在函数 A 中，我们需要重新启动函数 A，因为对该数据结构的迭代可以让我们找到不再存在的数据。我们可以指望方法 B 不会同时被调用两次(方法 A 将有时间完成)。

这可能吗？我正在使用 C++。请注意，仅锁定缓存是不够的。如果我们锁定缓存并接到一个电话说缓存已过期，我们需要立即重启函数 A 以实现正确的行为。

这不会正常工作，但我会尝试展示我需要的东西:

Class X
{
    Method A
    {
        for each //data structure
        {
            // do processing

            // check if our cache is out of date
            if(mRestart)
            {
                while(!mReadyToStart)
                    ; //wait

                mRestart = false;
                mReadyToStart = false;

                //Break, and call something that will recall this function.
            }                
            else
                return result; //return means we never needed to restart.
        }
    }

    Method B
    {
        mRestart = true;

        //Do processing

        mReadyToRestart = true;            
    }

    bool mRestart; // Init to false in constructor
}

Answer 1

您需要使用同步机制来保护 mRestart、mReadyToRestart 成员和您正在处理的数据结构免受并发访问。

根据您的特定需求、操作系统和构建环境，您可以使用 c++11 标准互斥锁或条件变量，或其他低级操作系统方法或框架(例如 boost::thread)在 c++ 中实现这一点。