C / C++ / MFC

<br />
 // Start the encoding process.<br />
    if ( SUCCEEDED( hr ) )<br />
    {<br />
        hr = pEncoder->PrepareToEncode(VARIANT_TRUE);<br />
    }<br />
    if ( SUCCEEDED( hr ) )<br />
    {<br />
        hr = pEncoder->Start();<br />
        // Keep the console window open.<br />
        printf("When encoding stops, press a key to close the console window.");<br />
<br />
        // Stop the encoding process.<br />
        if ( SUCCEEDED( hr ) )<br />
        {<br />
           <pre> // Wait for a key press.<br />
            while(!kbhit())  //this is due to console application<br />
               _asm nop;<br />
          </pre><br />
<br />
            hr = pEncoder->Stop();<br />
        }<br />
    }<br />
<br />
<br />

<br />
<br />
public void EncodeFromConsole()<br />
		{<br />
			glbEncoder.OnStateChange+=new _IWMEncoderEvents_OnStateChangeEventHandler(this.Encoder_OnStateChange); <br />
			bool boolEncodeStart = sEncodeFile(movie_source ,movie_dest );<br />
			if(boolEncodeStart)<br />
				Console.WriteLine("Encoding successfully started ");<br />
			glbboolStartNext= !boolEncodeStart;<br />
			FileInfo f = new FileInfo(movie_dest );<br />
			<br />
                      <pre><br />
                      while (!glbboolStartNext) <br />
			{<br />
				Application.DoEvents ();				<br />
					<br />
			}<br />
                      </pre>    <br />
				<br />
			Console.WriteLine  ("Finished - File " + movie_source + " is converted to " + movie_dest );<br />
			Application.Exit ();<br />
		}<br />

void DoEvents()
{
	MSG     msg;

	while (PeekMessage(&msg, NULL, 0, 0, PM_REMOVE)) {
		if(PreTranslateMessage(&msg) == FALSE) {
			TranslateMessage(&msg);
			DispatchMessage(&msg);
		}
	}

}

kakan wrote:

if(PreTranslateMessage(&msg) == FALSE) {

amitmistry_petlad wrote:

Are yaar i reading the same thing.

softwaremonkey wrote:

If CSemaphore::Release() is called multiple times by the same thread, does it increase the count each time

softwaremonkey wrote:

I am working on some code where one thread calls Release() each time it adds stuff to a queue, expecting a worker thread to fire the correct number of times to remove stuff from the queue. The code doesnt work properly and I suspect it is fundamentally flawed.

softwaremonkey wrote:

unprocessed items building up on the queue

I've been thinking about writing an article on this for about a year but haven't found the time yet.

long nObjectsAdded = 0;
CQueueObject* pObj = NULL;
::EnterCriticalSection( &m_csQueue ); //Block access for other threads
while( pObj = GetNewObject() )
{
    m_Queue.push( pObj );
    ++nObjectsAdded; //Keep track of the nbr of objects to release the semaphore accordingly
}
::LeaveCriticalSection( &m_csQueue ); // Stop blocking block other threads
::ReleaseSemaphore( m_hQueueSemaphore, nObjectsAdded, NULL ); // Unleash waiting thread

while( !bStopRunning )
{
    ::WaitForSingleObject( m_hQueueSemaphore, INFINITE ); //You hopefully have more handles to wait on ;)
    ::EnterCriticalSection( &m_csQueue ); //Block other thread
    CQueueObject* pObj = m_Queue.top();
    m_Queue.pop();
    ::LeaveCriticalSection( &m_csQueue ); //Stop blocking other thread

    //Do whatever you want with pObj here.
}