电竞比分网-中国电竞赛事及体育赛事平台

分享

例子演示如何創(chuàng)建一個新線程,動態(tài)分配內(nèi)存

 禁忌石 2017-05-29

示例

編輯
CreateThread 函數(shù)從一個進(jìn)程里面創(chuàng)建一個線程。這個開始的線程必須指定開始執(zhí)行代碼的地址,新線程執(zhí)行。有代表性的,開始地址就是一個函數(shù)名。這個函數(shù)有一個參數(shù),并且返回一個 DWORD 值。一個進(jìn)程里面同時有多個線程在執(zhí)行。
下面這個例子演示如何創(chuàng)建一個新線程,執(zhí)行本地定義的函數(shù)。 ThreadProc. 建立的線程動態(tài)分配內(nèi)存傳遞信息到每個線程的實例中。線程函數(shù)負(fù)責(zé)釋放這些內(nèi)存。
被調(diào)用的線程用 WaitForMultipleObjects 持續(xù)等待,直到所有的工作線程退出。在線程退出后,關(guān)掉線程函數(shù)的句柄。
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必須安裝 要不無此頭文件。此文件是為了實現(xiàn)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]);
    }    
}

    本站是提供個人知識管理的網(wǎng)絡(luò)存儲空間,所有內(nèi)容均由用戶發(fā)布,不代表本站觀點。請注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購買等信息,謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容,請點擊一鍵舉報。
    轉(zhuǎn)藏 分享 獻(xiàn)花(0

    0條評論

    發(fā)表

    請遵守用戶 評論公約

    類似文章 更多