在线程函数中传递整数数组

Question

我正在研究多个生产者和单个消费者问题。我想在线程函数中传递 Thread 像 1,2,3 这样，可以根据这些数字来命名单个线程。

但程序在创建线程时计数 7 后崩溃。我认为问题是由于 变量 nThreadNo; 如果我将计数限制为小于 7，它可以正常工作。但是如果我使计数超过此值，它就会崩溃。

void CEvent1Dlg::CreateProducerThreads()
{   

    try
    {
        nThreadNo = new int20]; 
        memset(nThreadNo,0,20);
        if (nThreadNo ==NULL) return;
    }catch(...)
    {
        MessageBox(_T("Memory allocation Failed"),_T("Thread"),1);
        return ;
    }
    int i = 0;
    for ( i = 0;i<20;i++)
    {   
        //nThreadNo = i+1;
        nThreadNo[i] = i+1;
        hWndProducer[i] = CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)ProducerThrdFunc,(void*)(nThreadNo+i),0,&dwProducerThreadID[i]);      
        if (hWndProducer[i] == NULL) 
        {
           //ErrorHandler(TEXT("CreateThread"));
           ExitProcess(3);
        }
    }   
    //WaitForMultipleObjects(20,hWndProducer,TRUE,INFINITE);            
}

DWORD WINAPI    ProducerThrdFunc ( LPVOID n )
{
    int *nThreadNo = (int*)n;       
    char chThreadNo[33];
    memset(chThreadNo,0,33);

    while(1)
    {
        itoa(*nThreadNo,chThreadNo,10);
        char* pMsg1 = new char[100];
        char* pMsg2 = new char[100];
        memset(pMsg1,0,100);
        memset(pMsg2,0,100);

        strcpy(pMsg1,"Producer ");      
        strcat(pMsg1," Thread No:");        
        strcat(pMsg1,chThreadNo);

        if (stThreadInfoProd.pEventQueue->AddTail(pMsg1)==TRUE)
        {
            strcpy(pMsg2,"Producer ");      
            strcat(pMsg2," Thread No:");        
            strcat(pMsg2,chThreadNo);
            strcat(pMsg2," Added the Msg");
        }
        else
        {
            strcpy(pMsg2,"Producer ");      
            strcat(pMsg2," Thread No:");        
            strcat(pMsg2,chThreadNo);
            strcat(pMsg2,"failed to Add the Msg");      
        }
        PostMessage(stThreadInfoProd.hWndHandle,UWM_ONUPDATEPRODUCERLIST,(WPARAM)pMsg2,0);
        strcat(pMsg1," Adding Msg:");
        //PostMessage(stThreadInfoProd.hWndHandle,UWM_ONUPDATEPRODUCERLIST,(WPARAM)pMsg2,0);        
        Sleep(3000);
    }   
    return 0;
}

Answer 1

1. 您正在将 nThreadNo 的前 20 个字节清零，而不是您应该做的 前 20 * sizeof(int) 字节。
2. 在此代码中还需要索引其他数组：hWndProducer、dwProducerThreadID。其中也有足够的元素吗？

Answer 2

CreateThread 调用正在传递整数值，但线程函数本身将其视为指向整数的指针。而不是这样：

int *nThreadNo = (int*)n;   

它可能应该是：

int nThreadNo = (int)n;   

编辑：我更仔细地查看了该调用，我确实看到它正在传递一个整数指针。但是，该值是堆栈数据，在线程尝试读取它时可能不存在。所以它可能应该只传递整数值：(void*)(nThreadNo[i])

Answer 3

这条线

if (nThreadNo ==NULL) return;

毫无价值。

现代 C++ 中的 new 运算符在失败时不会返回 NULL，它会抛出 std::badalloc 异常，但即使您使用返回 NULL 的分配器来指示失败，检测到它已经太晚了，您已经将 NULL 指针传递给了 memcpy。