1

我有一个环形缓冲区实现，我喜欢用它来处理传入的数据。考虑到需要同步，以下方法是否安全有效？

void CMyDlg::MyButton1()
{
    RingBuffer BufRing(10000);

    unsigned char InputBuf[100];
    unsigned char OutBuf[100];

    for (int ii = 0; ii < 1000; ++ii)
    {
        for (int i = 0; i < 100; ++i)
        {
            InputBuf[i] = i;
        }

        BufRing.Write(InputBuf,100);

        BufRing.Read(OutBuf,100);
        AfxBeginThread(WorkerThreadProc,OutBuf,THREAD_PRIORITY_NORMAL,0,0,NULL);
    }
}

UINT WorkerThreadProc( LPVOID Param )
{
    unsigned char* pThreadBuf = (unsigned char*)Param;

    for (int c = 0; c < 100; ++c)
    {
        TRACE("Loop %d elemnt %x\n",c,pThreadBuf[c]);
    }


    return TRUE;
}
4

1 回答 1

1

对我来说看起来很危险...

void CMyDlg::MyButton1()
{
    // ...
    unsigned char OutBuf[100];

    for (int ii = 0; ii < 1000; ++ii)
    {
        // ...

        BufRing.Read(OutBuf,100);
        AfxBeginThread(WorkerThreadProc,OutBuf,THREAD_PRIORITY_NORMAL,0,0,NULL);
    }
}

我看到的问题是您使用单个缓冲区 ( OutBuf) 来存储数据，将其传递给工作线程，然后在循环的下一次迭代中修改同一个缓冲区。

您的测试代码不会显示这一点，因为您只是OutBuf在每次迭代中重新填充相同的值（据我所知，无论如何）。如果您更改InputBuf[i] = i;为InputBuf[i] = ii;并在输出中包含唯一线程 ID TRACE，您可能会看到可疑行为。

于 2012-11-30T15:58:53.253 回答