用消息在Win32控制台程序多线程间进行通讯

#include <stdio.h>

#include <windows.h>

//#include <iostream>

//#include <process.h>

#define UM_MSG1 (WM_USER + 1)

#define UM_MSG2 (WM_USER + 2)

DWORD WINAPI Thread1(LPVOID para)

{

DWORD dwThreadId = *(DWORD *)para;

DWORD i = 0;

TCHAR *p;

char strTmp[100];

while(TRUE)

{

Sleep(1700);

p = new TCHAR[10];

sprintf_s(strTmp, 100, "Hello %d %x ", i++, p);

PostThreadMessage(dwThreadId, UM_MSG1, (WPARAM)strTmp, (LPARAM)p);

//delete []p;

}

return 0;

}

DWORD WINAPI Thread2(LPVOID para)

{

char strTmp[100];

DWORD dwThreadId = *(DWORD *)para;

DWORD i = 0;

TCHAR *p;

while(TRUE)

{

Sleep(3000);

p=new TCHAR[10];

sprintf_s(strTmp, 100, "World %d %x", i++, p);

PostThreadMessage(dwThreadId, UM_MSG2, (WPARAM)strTmp, (LPARAM)p);

//delete []p;

}

return 0;

}

int main()

{

printf("UM_MSG1: 0x%x/r/n", UM_MSG1);

printf("UM_MSG2: 0x%x/r/n", UM_MSG2);

DWORD dwValue = GetCurrentThreadId();

HANDLE hThread1 = CreateThread(NULL, 0, &Thread1, &dwValue, 0, NULL); // &Thread1可写作Thread1, 都是函数指针.

HANDLE hThread2 = CreateThread(NULL, 0, &Thread2, &dwValue, 0, NULL);

CloseHandle(hThread1);

CloseHandle(hThread2);

MSG msg;

while(GetMessage(&msg, NULL, 0, 0))

{

switch(msg.message)

{

case UM_MSG1:

case UM_MSG2:

printf("msg: 0x%x w: %x ws: %s l: %x/r/n", msg.message, &msg.wParam, msg.wParam, msg.lParam);

delete [](TCHAR *)msg.lParam; //注释掉这句你就会看到堆内存地址变化

break;

default:

printf("Unknown msg:0x%x/n",msg.message);

break;

}

Sleep(1);

}

return 0;

}