singleapartment.cpp

大学毕业前的最后一学期

#define _WIN32_WINNT 0x0400
#include <windows.h>
#include <iostream>

#include "..\TestComObject1\TestComObject1_i.c"
#include "..\TestComObject1\TestComObject1.h"

DWORD WINAPI ThreadProc(LPVOID lpv)
{

	HRESULT hr = CoInitializeEx(NULL, COINIT_APARTMENTTHREADED);

	if ( FAILED(hr) )
	{
		std::cout << "CoinitializeEx failed!" << std::endl;
		return 0;
	}

	ITestInterface1 *pTest = NULL;

	hr = ::CoCreateInstance(CLSID_TestInterface1,
							0,
							CLSCTX_INPROC,
							IID_ITestInterface1,
							(void**)&pTest);

	if ( FAILED(hr) )
	{
		std::cout << "CoCreateInstance failed!" << std::endl;
		return 0;
	}

	hr = pTest->TestFunc1();

	if ( FAILED(hr) )
	{
		std::cout << "TestFunc1 failed!" << std::endl;
		return 0;
	}
	

	pTest->Release();

	::CoUninitialize();

	return 0;
}

DWORD ApartMentMsgWaitForMultipleObject(HANDLE *hHandle,DWORD dwWaitCout, DWORD dwMilliseconds)
{

	BOOL bQuit = FALSE;
	DWORD dwRet;
	
	while(!bQuit)
	{
		int rc;
		rc = ::MsgWaitForMultipleObjects
								(
								dwWaitCout,          // 需要等待的对象数量
								hHandle,			// 对象树组
								FALSE,				//等待所有的对象
								(DWORD)dwMilliseconds,  // 等待的时间
								(DWORD)(QS_ALLINPUT | QS_ALLPOSTMESSAGE)     // 事件类型       
								);
		//等待的事件激发
		if( rc ==  WAIT_OBJECT_0 )
		{			
			dwRet = rc;	
			bQuit = TRUE;
		
		}
		//其他windows消息
		else if( rc == WAIT_OBJECT_0 + dwWaitCout )			
		{
			MSG msg;
			
			while (PeekMessage(&msg, NULL, 0, 0, PM_REMOVE))
			{
				TranslateMessage (&msg);
				DispatchMessage(&msg);
			}			
		} 
	}

	return dwRet;
}


int main(int argc, char* argv[])
{
	HRESULT hr = CoInitializeEx(NULL, COINIT_APARTMENTTHREADED);

	if ( FAILED(hr) )
	{
		std::cout << "CoinitializeEx failed!" << std::endl;
		return 0;
	}

	ITestInterface1 *pTest = NULL;

	hr = ::CoCreateInstance(CLSID_TestInterface1,
							0,
							CLSCTX_INPROC,
							IID_ITestInterface1,
							(void**)&pTest);

	if ( FAILED(hr) )
	{
		std::cout << "CoCreateInstance failed!" << std::endl;
		return 0;
	}
	
	hr = pTest->TestFunc1();
	
	if ( FAILED(hr) )
	{
		std::cout << "TestFunc1 failed!" << std::endl;
		return 0;
	}
	
	DWORD threadID;
	HANDLE hThreads[1];
	hThreads[0]  =   ::CreateThread(NULL,			//创建一个进程
		0,
		ThreadProc,
		(LPVOID)pTest,  //将pTest作为一个参数传入新线程
		0,
		&threadID);
	
	::WaitForSingleObject(hThreads,INFINITE);	//等待线程结束
	//ApartMentMsgWaitForMultipleObject(hThreads,1,INFINITE);
	
	
	::CloseHandle(hThreads);				//关闭线程句柄
	
	pTest->Release();
	
	::CoUninitialize();
	
	system("pause");
	
	return 0;
}