多线程将同一个文件映射至内存 - 编程论坛

最近在做一个项目,主要是处理一个大型数据文件，很自然的会用到多线程和文件内存映射。
在网上查阅资料发现，很多人在多个线程将同一文件的不同部分映射入内存时均失败，不知道是Windows本来不允许这样做还是本生程序有问题。
所以，今天写了哥程序测试了一下在多个线程中将同一文件的不同部分映射入内存的情况，根据项目的需要，只测试了在读状态下的映射。

首先，在.h文件中声明线程函数和线程参数

程序代码：

typedef struct tagTHRDPARAM
{
CString DAT_PATH;
}THRDPARAM;
UINT THRDFUNC1(LPVOID Param);
UINT THRDFUNC2(LPVOID Param);

线程参数只有一个参数，表示需要映射入内存的文件路径。两个线程函数如下：

程序代码：

UINT THRDFUNC1(LPVOID Param)
{
    DWORD FileSize;
    HANDLE hFile=CreateFile(((THRDPARAM*)Param)->DAT_PATH,GENERIC_READ,FILE_SHARE_READ,NULL,OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL,NULL);
    if(hFile==INVALID_HANDLE_VALUE)
    {
        MessageBox(NULL,_T("1创建文件内核对象失败"),_T("提示"),MB_ICONERROR);
        return 0;
    }
    FileSize=GetFileSize(hFile,NULL);

    HANDLE hFileMap=CreateFileMapping(hFile,NULL,PAGE_READONLY,0,0,NULL);
    if(hFileMap==NULL)
    {
        MessageBox(NULL,_T("1创建文件内核映射对象失败"),_T("提示"),MB_ICONERROR);
        CloseHandle(hFile);
        return 0;
    }
    PBYTE pMap=(PBYTE)MapViewOfFile(hFileMap,FILE_MAP_READ,0,0,16*64*1024);
    if(pMap==NULL)
    {
        MessageBox(NULL,_T("1将文件映射到内存空间时失败"),_T("提示"),MB_ICONERROR);
        CloseHandle(hFileMap);
        CloseHandle(hFile);
        return 0;
    }
    MessageBox(NULL,_T("1测试通过"),_T("提示"),MB_ICONINFORMATION);
    UnmapViewOfFile(pMap);
    CloseHandle(hFileMap);
    CloseHandle(hFile);
    return 0;
}

程序代码：

UINT THRDFUNC2(LPVOID Param)
{
    DWORD FileSize;
    HANDLE hFile=CreateFile(((THRDPARAM*)Param)->DAT_PATH,GENERIC_READ,FILE_SHARE_READ,NULL,OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL,NULL);
    if(hFile==INVALID_HANDLE_VALUE)
    {
        MessageBox(NULL,_T("2创建文件内核对象失败"),_T("提示"),MB_ICONERROR);
        return 0;
    }
    FileSize=GetFileSize(hFile,NULL);

    HANDLE hFileMap=CreateFileMapping(hFile,NULL,PAGE_READONLY,0,0,NULL);
    if(hFileMap==NULL)
    {
        MessageBox(NULL,_T("2创建文件内核映射对象失败"),_T("提示"),MB_ICONERROR);
        CloseHandle(hFile);
        return 0;
    }
    PBYTE pMap=(PBYTE)MapViewOfFile(hFileMap,FILE_MAP_READ,0,16*64*1024,16*64*1024);
    if(pMap==NULL)
    {
        MessageBox(NULL,_T("2将文件映射到内存空间时失败"),_T("提示"),MB_ICONERROR);
        CloseHandle(hFileMap);
        CloseHandle(hFile);
        return 0;
    }
    MessageBox(NULL,_T("2测试通过"),_T("提示"),MB_ICONINFORMATION);
    UnmapViewOfFile(pMap);
    CloseHandle(hFileMap);
    CloseHandle(hFile);
    return 0;
}

然后，在一个按钮的单击响应函数中，开启线程

程序代码：

void CMultiFileMapTestDlg::OnBnClickedStart()
{
    // TODO:
    THRDPARAM* pTHRDPARAM=new THRDPARAM;
    pTHRDPARAM->DAT_PATH=DAT_PATH;
    AfxBeginThread(THRDFUNC1,pTHRDPARAM);
    AfxBeginThread(THRDFUNC2,pTHRDPARAM);
}

测试结果表明，在只读（不写）的情况下测试通过了。