0

我的函数所做的是遍历一个布尔数组，并在找到一个设置为 false 的元素时，将其设置为 true。该函数是我的内存管理器单例类中的一个方法，它返回一个指向内存的指针。我收到一个错误，我的迭代器似乎循环并最终从头开始，我相信这是因为多个线程正在调用该函数。

void* CNetworkMemoryManager::GetMemory()
{
        WaitForSingleObject(hMutexCounter, INFINITE);

    if(mCounter >= NetConsts::kNumMemorySlots)
    {
       mCounter = 0;
    }

    unsigned int tempCounter = mCounter;

    unsigned int start = tempCounter;

    while(mUsedSlots[tempCounter])
    {
        tempCounter++;

        if(tempCounter >= NetConsts::kNumMemorySlots)
        {
            tempCounter = 0;
        }

        //looped all the way around
        if(tempCounter == start)
        {
            assert(false);
            return NULL;
        }
    }

    //return pointer to free space and increment

    mCounter = tempCounter + 1;
        ReleaseMutex(hMutexCounter);

    mUsedSlots[tempCounter] = true;
    return mPointers[tempCounter];
}

我的错误是在循环中发出的断言。我的问题是如何修复该功能，并且该错误是由多线程引起的吗？

编辑：添加了一个互斥锁来保护 mCounter 变量。没变。错误仍然出现。

4

1 回答 1

1

我不能说错误是否是由多线程引起的，但我可以说你的代码不是线程安全的。

你释放锁

ReleaseMutex(hMutexCounter);

然后访问 tempCounter 和 mUsedSlots：

mUsedSlots[tempCounter] = true;
return mPointers[tempCounter];

两者都不是 const。这是一场数据竞争，因为您没有正确序列化对这些变量的访问。

将其更改为：

mUsedSlots[tempCounter] = true;
const unsigned int retVal = mPointers[tempCounter];
ReleaseMutex(hMutexCounter);
return retVal;

那么至少你的代码是线程安全的，这是否解决了你的问题我不能说，试试看。在具有多核的机器上，由于数据竞争，会发生非常奇怪的事情。

作为一般的最佳实践，我建议查看一些 C++11 同步功能，例如std::mutexand std::lock_guard，这会让你摆脱自我，因为 std::lock_guard 会自动释放该锁定，因此你不会忘记，并且在这种情况下，你不能不经意间做得太早。这也将使您的代码更具可移植性。如果您还没有 C++11，请使用 boost 等价物。

于 2013-02-18T17:30:20.137 回答