C / C++ / MFC

<br />
//A message to send, message comes out as 49732<br />
const UINT TM_ON_DDE_MESSAGE	= ::RegisterWindowMessage( _T("TM_ON_DDE_MESSAGE"));<br />
<br />
------------------------------------------<br />
//The message sending line from the DDE Server<br />
::PostThreadMessage(gdwThreadId, TM_ON_DDE_MESSAGE, (WPARAM) pInToWindow, 0);	<br />
<br />
------------------------------------------<br />
<br />
//The code used to start the thread<br />
//Start a thread to receive the messages from the DDE Server.<br />
		gdwThreadId = 0;<br />
		ghThread = ::CreateThread( <br />
			NULL,                        // default security attributes <br />
			0,                           // use default stack size  <br />
			DDEServerThreadFunc,         // thread function <br />
			this,						 // argument to thread function <br />
			0,                           // use default creation flags <br />
			&gdwThreadId);                // returns the thread identifier <br />
<br />
		// Check the return value for success.<br />
		char szMsg[50];<br />
		if (ghThread == NULL) <br />
		{<br />
			wsprintf( szMsg, "CreateThread failed. Unable to receive DDE messages from the Acrobat search plugin" ); <br />
			AfxMessageBox( szMsg, MB_OK );<br />
		}<br />
<br />
------------------------------------------<br />
<br />
//The thread message pump.<br />
WORD CDDEServer::OnWndThread()<br />
{<br />
	MSG msg;<br />
	m_keepThreadLoopGoing = TRUE;<br />
	// Wait here for messages or WM_QUIT to exit or for m_keepThreadLoopGoing to become false.<br />
	while ( ::GetMessage( &msg, NULL, 0, 0 ) != 0 && m_keepThreadLoopGoing) {<br />
		if ( !OnThreadProcess( msg.message, msg.wParam, msg.lParam ) ) {<br />
			// trace out messages for detailed debug purposes.<br />
			::DispatchMessage( &msg );<br />
		}<br />
	}<br />
	return static_cast<DWORD>( msg.wParam );	// thread exiting...<br />
}<br />
<br />
//Process thread messages, i.e in this case watch for the close thread message<br />
BOOL CDDEServer::OnThreadProcess( UINT uMsg, WPARAM wParam, LPARAM /*lParam*/ )<br />
{<br />
	bool bProcessed = true;<br />
	// require a critical section to wrap these APIs<br />
	// to avoid method re-entrant problems later.<br />
	if (uMsg == TM_ON_DDE_MESSAGE)<br />
	{//Received a DDE message.<br />
		if (wParam) {<br />
			CCriticalSection threadsafe;<br />
			threadsafe.Lock();<br />
			OnRunDDECommand( (WINDOW_LUGGAGE*) wParam);<br />
			threadsafe.Unlock();<br />
		}<br />
		bProcessed = true;<br />
	} else {<br />
		bProcessed = false;<br />
	}	<br />
	return bProcessed;<br />
}