需要:优雅的比赛条件解决方案

我有以下代码:

class TimeOutException
{};

template <typename T>
class MultiThreadedBuffer
{
public:
    MultiThreadedBuffer()
    {
        InitializeCriticalSection(&m_csBuffer);
        m_evtDataAvail = CreateEvent(NULL, TRUE, FALSE, NULL);
    }
    ~MultiThreadedBuffer()
    {
        CloseHandle(m_evtDataAvail);
        DeleteCriticalSection(&m_csBuffer);
    }
    void LockBuffer()
    {
        EnterCriticalSection(&m_csBuffer);
    }
    void UnlockBuffer()
    {
        LeaveCriticalSection(&m_csBuffer);
    }
    void Add(T val)
    {
        LockBuffer();
        m_buffer.push_back(val);
        SetEvent(m_evtDataAvail);
        UnlockBuffer();
    }
    T Get(DWORD timeout)
    {
        T val;
        if (WaitForSingleObject(m_evtDataAvail, timeout) == WAIT_OBJECT_0) {
            LockBuffer();

            if (!m_buffer.empty()) {
                val = m_buffer.front();
                m_buffer.pop_front();
            }

            if (m_buffer.empty()) {
                ResetEvent(m_evtDataAvail);
            }

            UnlockBuffer();
        } else {
            throw TimeOutException();
        }
        return val;
    }
    bool IsDataAvail()
    {
        return (WaitForSingleObject(m_evtDataAvail, 0) == WAIT_OBJECT_0);
    }
    std::list<T> m_buffer;
    CRITICAL_SECTION m_csBuffer;
    HANDLE m_evtDataAvail;
};

单元测试表明,只要T的默认构造函数和复制/分配操作符不抛出,在单个线程上使用该代码就可以正常工作。既然我在写T,那是可以接受的。

我的问题是获取方法。如果没有可用的数据(即未设置m-evtdataavil),则可以在WaitForSingleObject调用上阻塞多个线程。当新数据可用时,它们都会进入lock()调用。只有一个会通过,并且可以获取数据并继续前进。在unlock()之后,另一个线程可以继续运行,将发现没有数据。当前它将返回默认对象。

我要做的是让第二个线程(和其他线程)返回到waitForSingleObject调用。我可以添加一个解锁并执行goto的其他块,但这感觉很邪恶。

该解决方案还增加了无限循环的可能性,因为每次回程都会重新启动超时。我可以添加一些代码来检查输入时的时钟,并在每次返回时调整超时,但是这个简单的get方法开始变得非常复杂。

对于如何在保持可测试性和简单性的同时解决这些问题有什么想法吗?

哦,对于任何想知道的人来说,isdataavail函数只存在于测试中。它不会在生产代码中使用。添加和获取是将在非测试环境中使用的唯一方法。