CreateThread参数值意外更改

CreateThread parameter value changes unexpectedly

本文关键字：意外 参数 CreateThread      更新时间：2023-10-16

我试图创建4个线程，以便在我的4个CPU内核上同时运行一个函数。我调用的函数将根据val变量值更改一些循环偏移。

我试过这个，但它没有正确地增加val计数器，一些线程报告相同的值，它似乎随机变化：

int val = 1;
threads[0] = CreateThread(0, 0, my_thread_1, &val, 0, 0);
val++;
threads[1] = CreateThread(0, 0, my_thread_1, &val, 0, 0);
val++;
threads[2] = CreateThread(0, 0, my_thread_1, &val, 0, 0);
val++;
threads[3] = CreateThread(0, 0, my_thread_1, &val, 0, 0);

但这似乎很有效：

int val1 = 1;
int val2 = 2;
int val3 = 3;
int val4 = 4;
threads[0] = CreateThread(0, 0, my_thread_1, &val1, 0, 0);
threads[1] = CreateThread(0, 0, my_thread_1, &val2, 0, 0);
threads[2] = CreateThread(0, 0, my_thread_1, &val3, 0, 0);
threads[3] = CreateThread(0, 0, my_thread_1, &val4, 0, 0);

这可能是什么原因，以及如何正确地为线程提供一些参数？

这是我的功能：

DWORD WINAPI my_thread_1(void *params){ 
    int val = *(int *)params;
...
}

这之所以失败，只是因为在第一个示例中，您将指针传递到所有4个线程的相同内存位置。在传递指针之前递增值这一事实无关紧要，因为内存位置保持不变。

在第二个示例中，您将4个互斥指针传递给4个线程。因此，线程都读取独立的值。

您可以稍微重组代码以帮助提高可维护性和灵活性：

int threadData[NTHREADS]; /* in the future this could be an array of structs */
HANDLE threads[NTHREADS];
int tt;
for (tt = 0; tt < NTHREADS; ++tt)
{
    threadData[tt] = tt + 1; /* placeholder for actual logic */
    threads[tt] = CreateThread(
        NULL,            /* lpThreadAttributes */
        0,               /* dwStackSize */
        my_thread_1,     /* lpStartAddress */
        &threadData[tt], /* lpParameter: each thread will receive its own data */
        0,               /* dwCreationFlags */
        NULL             /* lpThreadId */);
}
/* Since threadData and threads are local to the enclosing scope,
 * we must wait for them to finish here to ensure we don't read
 * data we no longer own
 */
WaitForMultipleObjects(NTHREADS, threads, TRUE, INFINITE);

在第一种情况下，将同一对象传递给所有线程。在第二种情况下，您正在传递不同的对象。

在这两种情况下，都存在一个潜在的问题，即如果创建线程的函数返回，那么所有创建的线程都将具有指向已不存在的int的指针，因为所有int对象都是创建线程的功能的本地对象。这会调用未定义的行为。

所以，如果函数不等待并返回，那么在这种情况下，不应该将指针传递给本地对象，而应该传递动态分配的对象：

int *v1 = new int;
threads[0] = CreateThread(0, 0, my_thread_1, v1 , 0, 0);

多个线程同时访问同一内存。您应该使用互斥或信号量来独占访问关键部分中的变量。

相关文章：