C++中实现多线程文件写入

在 C++ 程序设计中，多线程文件写入是一个常见但复杂的任务。本文将详细介绍如何使用 Windows API 进行文件操作和线程管理，确保数据的一致性和程序的稳定性。

关键组件解析

1. 文件 IO 操作

使用 CreateFile 函数打开或创建文件，并通过 WriteFile 函数执行写入操作。这两个函数是文件操作的基础，能够处理各种文件读写需求。

2. 多线程创建

通过 CreateThread 函数创建新线程。每个线程都可以独立执行指定的任务，从而提高程序的并发性能。

3. 线程同步与资源控制

为了防止多个线程同时访问同一资源导致的数据冲突，使用 CRITICAL_SECTION 结构体来实现线程间的同步。此外，WaitForMultipleObjects 函数用于等待多个线程完成其任务。

示例代码

// ThreadWrite.cpp : 定义控制台应用程序的入口点。
#include 

HANDLE fileHandle;
CRITICAL_SECTION criticalSection;

DWORD WINAPI writeToFile(LPVOID lParam) {
    int threadNum = (int)lParam;
    printf("线程 %d: 开始工作...\n", threadNum);
    DWORD bytesWritten;
    for (int i = 0; i <1000; ++i) {
        EnterCriticalSection(&criticalSection);
        char buffer[1024];
        sprintf(buffer, "线程 %d: Hello World!\n", threadNum);
        WriteFile(fileHandle, buffer, strlen(buffer), &bytesWritten, NULL);
        LeaveCriticalSection(&criticalSection);
    }
    printf("线程 %d: 工作完成...\n", threadNum);
    return 0;
}

int main() {
    HANDLE threads[5];
    DWORD threadID;
    fileHandle = CreateFile(TEXT("C:\\11.txt"), GENERIC_WRITE, FILE_SHARE_READ | FILE_SHARE_WRITE, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
    if (fileHandle == INVALID_HANDLE_VALUE) {
        printf("无法创建文件，错误码：%d\n", GetLastError());
        getchar();
        return 0;
    }
    InitializeCriticalSection(&criticalSection);
    for (int i = 0; i <5; ++i) {
        threads[i] = CreateThread(NULL, 0, writeToFile, (LPVOID)(i + 1), 0, &threadID);
        printf("线程 %d 创建成功！\n", (i + 1));
    }
    WaitForMultipleObjects(5, threads, TRUE, INFINITE);
    DeleteCriticalSection(&criticalSection);
    CloseHandle(fileHandle);
    getchar();
    return 0;
}

以上代码展示了如何在 C++ 中使用多线程技术安全地进行文件写入。通过合理使用临界区和线程同步机制，可以有效避免数据竞争问题，保证程序的稳定运行。