C / C++ / MFC

<br />
<br />
CPrimeTest { <br />
public: <br />
	<br />
	{ <br />
		// Create a thread that will calculate the prime numbers <br />
		CWinThread* pThread; <br />
		pThread = ::AfxBeginThread( PrimeCalcProc, this, 0, 0, CREATE_SUSPENDED, NULL); <br />
		pThread->m_bAutoDelete = FALSE; <br />
		pThread->ResumeThread(); <br />
		// Calcuate the first 10 prime numbers in the series on the thread <br />
		for( UINT i = 0; i < 10; i++ ) <br />
		{ <br />
			// Signal the thread to do the next work item <br />
			m_pCalcNext->SetEvent(); <br />
			// Wait for the thread to complete the current task <br />
			::WaitForSingleObject( m_pCalcFinished->m_hObject, INFINITE ); <br />
			// Print the result <br />
			TRACE( "The value of m_iCurrentPrime is: %d\n", m_iCurrentPrime ); <br />
		} <br />
		// Notify the worker thread to exit and wait for it to complete m_pTerminateThread->SetEvent(); <br />
		::WaitForSingleObject( pThread->m_hThread, INFINITE ); <br />
		delete pThread; } <br />
	<br />
	~CPrimeTest() <br />
	{ <br />
		delete m_pCalcNext; <br />
		delete m_pCalcFinished; <br />
		delete m_pTerminateThread; <br />
	} <br />
private: <br />
	// Determines whether the given number is a prime number static <br />
	BOOL IsPrime( INT ThisPrime ) <br />
	{ <br />
		if( ThisPrime < 2 ) return FALSE; <br />
		for( INT n = 2; n < ThisPrime; n++ ) <br />
		{ <br />
			if( ThisPrime % n == 0 ) <br />
				<br />
				return FALSE; <br />
		} <br />
		return TRUE; <br />
	} <br />
	// Calculates the next prime number in the series static <br />
	INT NextPrime( INT ThisPrime ) <br />
	{ while( TRUE ) <br />
	{ if( IsPrime( ++ThisPrime ) ) <br />
	{ return ThisPrime; } } } <br />
	// Worker thread responsible for calculating the next prime <br />
	// number in the series <br />
	static UINT __cdecl PrimeCalcProc( LPVOID lpParameter ) <br />
	{ CPrimeTest* pThis = static_cast<CPrimeTest*>( lpParameter ); <br />
	VERIFY( pThis != NULL ); VERIFY( pThis->m_pCalcNext != NULL ); <br />
	VERIFY( pThis->m_pCalcFinished != NULL ); <br />
	VERIFY( pThis->m_pTerminateThread != NULL ); <br />
	// Create a CMultiLock object to wait on the various events <br />
	// WAIT_OBJECT_0 refers to the first event in the array, WAIT_OBJECT_0+1 refers to the second <br />
	CSyncObject* pWaitObjects[] = { pThis->m_pCalcNext, pThis->m_pTerminateThread }; <br />
	CMultiLock MultiLock( pWaitObjects, 2L ); <br />
	while( MultiLock.Lock( INFINITE, FALSE ) == WAIT_OBJECT_0 ) <br />
	{ <br />
		// Calculate next prime <br />
		pThis->m_iCurrentPrime = NextPrime( pThis->m_iCurrentPrime ); <br />
		// Notify main thread calculation is complete <br />
		pThis->m_pCalcFinished->SetEvent(); <br />
	} <br />
	// Terminate the thread <br />
	::AfxEndThread( 0, FALSE ); <br />
	return 0L; <br />
	} CEvent* m_pCalcNext; <br />
	// notifies worker thread to calculate next prime <br />
	CEvent* m_pCalcFinished; <br />
	// notifies main thread current calculation is complete <br />
	CEvent* m_pTerminateThread; <br />
	// notifies worker thread to terminate INT m_iCurrentPrime; <br />
	// current calculated prime number <br />
};<br />
<br />
<br />
<br />
<br />