使用 Win32 的多线程

Posted 2023-02-21

【中文标题】使用 Win32 的多线程

【英文标题】：Multiple Threads using Win32

【发布时间】：2015-10-20 05:41:00

【问题描述】：

我正在用 C 语言编写一个多线程 ASCII 字符计数器。当我将 NUM_THREADS 设置为 1 时，该程序可以正常工作，但它会因任何其他数字而崩溃。这是我的第一个可变多线程分配，我以为我什么都懂，但我想我错过了一些东西。

这是我所拥有的：

#include <stdio.h>
#include <windows.h>

#define BUF_SIZE 65536
#define NUM_THREADS 2

struct ThreadInfo 
    char buffer[BUF_SIZE];
    int threadNum;
    int firstIndex;
    int lastIndex;
;


int char_count[NUM_THREADS][128];
int bytesRead = 0;

DWORD WINAPI countChars(struct ThreadInfo *threadInfo);

int main(int argc, char* argv[])
    DWORD ThreadId[NUM_THREADS];
    HANDLE ThreadHandles[NUM_THREADS];
    struct ThreadInfo threadInfo;
    char buffer[BUF_SIZE];

    buffer[BUF_SIZE - 1] = '\0';

    if(argc < 2)
        printf("Usage Error: Incorrect number of arguments.\n");
        printf("Usage: ASCIICount <file1>\n");
        return 1;
    

    for(int i = 0; i < NUM_THREADS; i++)
        for (int j = 0; j < sizeof(char_count); j++) 
            char_count[i][j] = 0;
        
    

   HFILE file1 = CreateFile(argv[1], 
       GENERIC_READ,
       0,
       NULL,
       OPEN_EXISTING,
       FILE_ATTRIBUTE_NORMAL,
       NULL);

   if(file1 == INVALID_HANDLE_VALUE)
       printf("Error opening %s.\n", argv[1]);
       return 1;
   

   ReadFile(file1, buffer, sizeof(buffer)-1, &bytesRead, NULL);

   strcpy(threadInfo.buffer, buffer);

   for (int i = 0; i < NUM_THREADS; i++) 
       threadInfo.threadNum = i;
       threadInfo.firstIndex = (i)*((bytesRead/NUM_THREADS));
       threadInfo.lastIndex = (i+1)*(bytesRead/NUM_THREADS) - 1;

       ThreadHandles[i] = CreateThread(
           NULL, //default security attributes
           0, // default stack size
           countChars, // thread function
           &threadInfo, // parameter to thread function
           0, // default creation flags
           &ThreadId[i]);
   

   for (int i = 0; i < NUM_THREADS; i++) 
       if (ThreadHandles[i] != NULL) 
           // now wait for the thread to finish
           WaitForSingleObject(ThreadHandles[i], INFINITE);

          //close the thread handle
          CloseHandle(ThreadHandles[i]);
       
   

   printf("Buffer size: %d\n", sizeof(buffer));
   printf("Bytes read: %d\n", bytesRead);
   for (int i = 0; i < NUM_THREADS; i++) 
       for (int j = 0; j < 128; j++) 
           if (j < 33 || j == 127) 
               printf("%d, %#x, %d\n", j, j, char_count[i][j]);
           
           else 
               printf("%d, %c: %d\n", j, j, char_count[i][j]);
           
       
   
   return 0;


DWORD WINAPI countChars(struct ThreadInfo *threadInfo)
    char cur_char;
    for(int i = threadInfo->firstIndex; i < threadInfo->lastIndex; i++)
        cur_char = threadInfo->buffer[i];
        char_count[threadInfo->threadNum][cur_char]++;
    
    return 0;

【问题讨论】：

我想我刚刚意识到这一点。一旦我创建了一个使用该 threadInfo 的线程，我将更改 threadInfo 的值。所以解决方案是有一个 NUM_THREADS threadInfos 数组

每个线程都需要自己的ThreadInfo，目前它们都使用同一个。

叮叮叮。谢谢！

【参考方案1】：

正如Jonathan Potter 指出的那样

"每个线程都需要自己的 ThreadInfo"