WinAPI的睡眠在子线程内不工作

Question

我是一个初学者，我试图重现一个rae条件，以便使自己熟悉这个问题。为此，我创建了以下程序：

#include <Windows.h>
#include <iostream>

using namespace std;

#define numThreads 1000

DWORD __stdcall addOne(LPVOID pValue)
{
    int* ipValue = (int*)pValue;
    *ipValue += 1;
    Sleep(5000ull);
    *ipValue += 1;
    return 0;
}

int main()
{
    int value = 0;
    HANDLE threads[numThreads];

    for (int i = 0; i < numThreads; ++i)
    {
        threads[i] = CreateThread(NULL, 0, addOne, &value, 0, NULL);
    }

    WaitForMultipleObjects(numThreads, threads, true, INFINITE);

    cout << "resulting value: " << value << endl;
    return 0;
}

我在线程的函数中添加了睡眠，以便重现竞争条件，因为，我是如何理解的，如果我只是添加一个作为工作负载，竞争条件不会表现出来：创建了一个线程，然后它运行工作负载，并且它恰好在另一个迭代中创建的另一个线程开始其工作负载之前完成。我的问题是工作负载中的睡眠（）似乎被忽略了。我将参数设置为5sec，我希望程序至少运行5秒，但它会立即完成。当我将睡眠（5000）放在main函数中时，程序会按预期运行（

结果值：1000

而正确答案应该是2000年。你能猜到为什么会发生这种情况吗？

Answer 1

杰里·科芬（Jerry Coffin）给出了正确的答案，但为了避免你输入：

#include <Windows.h>
#include <iostream>
#include <assert.h>

using namespace std;

#define numThreads 1000

DWORD __stdcall addOne(LPVOID pValue)
{
    int* ipValue = (int*)pValue;
    *ipValue += 1;
    Sleep(5000);
    *ipValue += 1;
    return 0;
}

int main()
{
    int value = 0;
    HANDLE threads[numThreads];

    for (int i = 0; i < numThreads; ++i)
    {
        threads[i] = CreateThread(NULL, 0, addOne, &value, 0, NULL);
    }

    DWORD Status = WaitForMultipleObjects(numThreads, threads, true, INFINITE);

    assert(Status != WAIT_FAILED);

    cout << "resulting value: " << value << endl;
    return 0;
}

当出现错误时，请确保已断言任何可能失败的Windows API函数的返回值。如果您确实非常需要等待大量线程，可以通过链接来克服64个线程的限制。一、 例如，每增加64个线程，你就要牺牲一个线程，这个线程的唯一目的就是等待其他64个线程等等。我们（Windows Developer’s Journal）几年前发表了一篇文章来演示这项技术，但我记不起作者的名字了。

Answer 2

WaitForMultipleObjects一次最多只允许等待MAXIMUM_WAIT_OBJECTS(当前为64个)线程。如果你考虑到这一点:

#include <Windows.h>
#include <iostream>

using namespace std;

#define numThreads MAXIMUM_WAIT_OBJECTS

DWORD __stdcall addOne(LPVOID pValue) {
    int* ipValue=(int*)pValue;
    *ipValue+=1;
    Sleep(5000);
    *ipValue+=1;
    return 0;
}

int main() {
    int value=0;
    HANDLE threads[numThreads];

    for (int i=0; i < numThreads; ++i) {
        threads[i]=CreateThread(NULL, 0, addOne, &value, 0, NULL);
    }

    WaitForMultipleObjects(numThreads, threads, true, INFINITE);

    cout<<"resulting value: "<<value<<endl;
    return 0;
}

…事情比你预期的要多得多。当然，你是否真的会看到比赛条件的结果是一个相当不同的故事——但是在多次运行中，我确实看到结果值略有变化（例如，125左右的低点）。