分享

例子演示如何创建一个新线程,动态分配内存

 禁忌石 2017-05-29

示例

编辑
CreateThread 函数从一个进程里面创建一个线程。这个开始的线程必须指定开始执行代码的地址,新线程执行。有代表性的,开始地址就是一个函数名。这个函数有一个参数,并且返回一个 DWORD 值。一个进程里面同时有多个线程在执行。
下面这个例子演示如何创建一个新线程,执行本地定义的函数。 ThreadProc. 建立的线程动态分配内存传递信息到每个线程的实例中。线程函数负责释放这些内存。
被调用的线程用 WaitForMultipleObjects 持续等待,直到所有的工作线程退出。在线程退出后,关掉线程函数的句柄。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
#include <windows.h>
#include <strsafe.h>//win2003SDK必须安装 要不无此头文件。此文件是为了实现StringCchPrintf,StringCchLength。
#define MAX_THREADS    3
#define BUF_SIZE    255
typedef struct _MyData{
int val1;
int val2;
}MYDATA,*PMYDATA;
DWORD WINAPI ThreadProc(LPVOID lpParam)
{
    HANDLE hStdout;
    PMYDATA pData;
    TCHAR msgBuf[BUF_SIZE];
    size_tcchStringSize;
    DWORD dwChars;
    hStdout=GetStdHandle(STD_OUTPUT_HANDLE);
    if(hStdout==INVALID_HANDLE_VALUE)
    return 1;
    //Cast the parameter to the correct data type.
    pData=(PMYDATA)lpParam;
    //Print the parameter values using thread-safe functions.
    StringCchPrintf(msgBuf,BUF_SIZE,TEXT("Parameters=%d,%d\n"),
    pData->val1,pData->val2);
    StringCchLength(msgBuf,BUF_SIZE,&cchStringSize);
    WriteConsole(hStdout,msgBuf,cchStringSize,&dwChars,NULL);
    //Free the memory allocated by the caller for the thread
    //data structure.
    HeapFree(GetProcessHeap(),0,pData);
    return 0;
}
void main()
{
    PMYDATA pData;
    DWORD dwThreadId[MAX_THREADS];
    HANDLE hThread[MAX_THREADS];
    int i;
    //Create MAX_THREADS worker threads.
    for(i = 0; i < MAX_THREADS; i++)
    {
        //Allocate memory for thread data.
        pData=(PMYDATA)HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,
        sizeof(MYDATA));
        if(pData==NULL)
        ExitProcess(2);
        //Generate unique data for each thread.
        pData->val1=i;
        pData->val2=i+100;
        hThread[i]=CreateThread(
        NULL,//default security attributes
        0,//use default stack size
        ThreadProc,//thread function
        pData,//argument to thread function
        0,//use default creation flags
        &dwThreadId[i]);//returns the thread identifier
        //Check there turn value for success.
        if(hThread[i]==NULL)
        {
            ExitProcess(i);
        }
    }
    //Wait until all threads have terminated.
    WaitForMultipleObjects(MAX_THREADS,hThread,TRUE,INFINITE);
    //Close all thread handle supon completion.
    for(i=0;i<MAX_THREADS;i++)
    {
        CloseHandle(hThread[i]);
    }    
}

    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多