• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            使用PostThreadMessage在Win32線程間傳遞消息

            PostThreadMessage的原型是這樣的

            BOOL PostThreadMessage( DWORD idThread,
                UINT Msg,
                WPARAM wParam,
                LPARAM lParam
            );

            PostThreadMessage可以用于線程之間的異步通訊,因?yàn)樗挥玫却{(diào)用者返回,
            這也許是線程通訊中最簡(jiǎn)單的一種方法了。

            但是要注意以下問題
            1 .PostThreadMessage有時(shí)會(huì)失敗,報(bào)1444錯(cuò)誤(Invalid thread identifier. )
            其實(shí)這不一定是線程不存在的原因,也有可能是線程不存在消息隊(duì)列(message queue)造成的。
            事實(shí)上,并不是每個(gè)thread都有message queue,那如何讓thread具有呢?
            答案是,至少調(diào)用message相關(guān)的function一次,比如GetMessage,PeekMessage。

            2.如果是post動(dòng)態(tài)分配的memory給另外一個(gè)thread,要注意內(nèi)存的正確釋放。

            3.PostThreadMessage不能夠post WM_COPYDATE之類的同步消息,否則會(huì)報(bào)錯(cuò)

            4.最好不要使用PostThreadMessage post message給一個(gè)窗口,使用PostMessage替代。

            下面是我寫的一個(gè)比較嚴(yán)整的例子,僅供參考。

            #include <windows.h>
            #include 
            <cstdio>
            #include 
            <process.h>

            #define MY_MSG WM_USER+100
            const int MAX_INFO_SIZE = 20;

            HANDLE hStartEvent; 
            // thread start event

            // thread function
            unsigned __stdcall fun(void *param)
            {
                printf(
            "thread fun start\n");

                MSG msg;
                PeekMessage(
            &msg, NULL, WM_USER, WM_USER, PM_NOREMOVE);

                
            if(!SetEvent(hStartEvent)) //set thread start event 
                {
                    printf(
            "set start event failed,errno:%d\n",::GetLastError());
                    
            return 1;
                }
                
                
            while(true)
                {
                    
            if(GetMessage(&msg,0,0,0)) //get msg from message queue
                    {
                        
            switch(msg.message)
                        {
                        
            case MY_MSG:
                            
            char * pInfo = (char *)msg.wParam;
                            printf(
            "recv %s\n",pInfo);
                            delete[] pInfo;
                            
            break;
                        }
                    }
                };
                
            return 0;
            }

            int main()
            {
                HANDLE hThread;
                unsigned nThreadID;

                hStartEvent 
            = ::CreateEvent(0,FALSE,FALSE,0); //create thread start event
                if(hStartEvent == 0)
                {
                    printf(
            "create start event failed,errno:%d\n",::GetLastError());
                    
            return 1;
                }

                
            //start thread
                hThread = (HANDLE)_beginthreadex( NULL, 0&fun, NULL, 0&nThreadID );
                
            if(hThread == 0)
                {
                    printf(
            "start thread failed,errno:%d\n",::GetLastError());
                    CloseHandle(hStartEvent);
                    
            return 1;
                }

                
            //wait thread start event to avoid PostThreadMessage return errno:1444
                ::WaitForSingleObject(hStartEvent,INFINITE);
                CloseHandle(hStartEvent);

                
            int count = 0;
                
            while(true)
                {
                    
            char* pInfo = new char[MAX_INFO_SIZE]; //create dynamic msg
                    sprintf(pInfo,"msg_%d",++count);
                    
            if(!PostThreadMessage(nThreadID,MY_MSG,(WPARAM)pInfo,0))//post thread msg
                    {
                        printf(
            "post message failed,errno:%d\n",::GetLastError());
                        delete[] pInfo;
                    }
                    ::Sleep(
            1000);
                }

                CloseHandle(hThread);
                
            return 0;
            }

            posted on 2006-01-12 23:08 zmj 閱讀(1078) 評(píng)論(0)  編輯 收藏 引用


            只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
            網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


            久久人人爽人人爽人人片AV东京热| 人妻少妇久久中文字幕一区二区| 国产精品美女久久久网AV| 久久99国产精品一区二区| 久久中文精品无码中文字幕| 香蕉久久久久久狠狠色| 国产高潮国产高潮久久久| 很黄很污的网站久久mimi色| 久久妇女高潮几次MBA| 色综合久久久久| 无码人妻久久一区二区三区免费| 91精品国产91久久综合| 2021久久精品免费观看| 色综合久久最新中文字幕| 久久人与动人物a级毛片| 青青草国产成人久久91网| 欧美熟妇另类久久久久久不卡 | 国产精品久久婷婷六月丁香| 国产精品免费看久久久| 久久久久av无码免费网| 91精品日韩人妻无码久久不卡| 狠狠综合久久综合88亚洲| 精品无码久久久久久国产| 人妻精品久久无码区| 思思久久99热只有频精品66| 亚洲国产成人久久精品影视| 99麻豆久久久国产精品免费| 国产精品中文久久久久久久| 久久一区二区三区免费| 91超碰碰碰碰久久久久久综合| 久久久一本精品99久久精品66 | 久久久精品人妻一区二区三区四 | 精品欧美一区二区三区久久久| 久久久精品国产免大香伊| 无码精品久久一区二区三区 | 久久精品麻豆日日躁夜夜躁| 国产精品久久久久久久app | 国产精品久久久天天影视| 久久精品国产第一区二区三区| 久久天天躁狠狠躁夜夜2020一 | 亚洲AV日韩精品久久久久久 |