递归同步

Question

在我的应用程序中，两个线程调用相同的递归函数，应该将数据输出到某个文件。我不知道如何同步这些线程以输出正确的数据。我尝试了一些带有互斥锁的变体（在代码中使用 /** n **/ 注释），但它不起作用（输出数据来自不同的线程）。如何组织同步（我应该只使用 WinAPI 和 std）。伪代码如下：

HANDLE hMutex = CreateMutex(NULL,FALSE, 0);
wchar_t** HelpFunction(wchar_t const* p, int *t)
{
    do
    {
        /**** 1 ****/ //WaitForSingleObject(hMutex, INFINITE);
        wchar_t* otherP= someFunction();
        if(...)
        {
            /**** 2 ****/ //WaitForSingleObject(hMutex, INFINITE);
            //File's output should be here
            //Outputing p
            /**** 2 ****/ //ReleaseMutex(hMutex);
        }
        if(...)
        {
            HelpFunction(otherP, t);
        }
        /**** 1 ****/ //ReleaseMutex(hMutex);
    }while(...);
}
unsigned int WINAPI ThreadFunction( void* p)
{
    int t = 0;
    /**** 3 ****/ //WaitForSingleObject(hMutex, INFINITE);
    wchar_t** res = HelpFunction((wchar_t *)p, &t);
    /**** 3 ****/ //ReleaseMutex(hMutex);
    return 0;
}
void _tmain()
{
    HANDLE hThreads[2];
    hThreads[0] = (HANDLE)_beginthreadex(NULL, 0, ThreadFunction, L"param1", 0, NULL);
    hThreads[1] = (HANDLE)_beginthreadex(NULL, 0, ThreadFunction, L"param2", 0, NULL);
    WaitForMultipleObjects(2, hThreads, TRUE, INFINITE);
}

Answer 1

对于 Windows API，如果它是单个进程，则最好使用关键部分。

临界区不需要 WaitForSingleObject，只有在等待某些数据写入时才使用它。

我猜你正在同步的是文件写入，所以每个线程一次写入一条完整的记录。 （确保刷新所有缓冲区）。

你会打电话的

EnterCriticalSection

当你到达敏感部分时

LeaveCriticalSection

在敏感部分的末尾。

并查看here 以获取更多详细信息 API。

这里的递归无关紧要，只要您在递归时没有持有“锁”，即您不在关键部分代码中进行递归。当您使用所示代码进行递归时，它不会产生新线程。我不知道你是否期待它。

我实际上在您的 HelpFunction 中看不到任何文件 I/O。但是，我确实看到了您刚刚称为 t 的指针。它是两个线程的相同指针，并且它是非常量的。因此，如果两个线程都将写入该 int，您可能也需要同步它。再一次，您的代码实际上并未显示该指针的使用方式。