TB10.1 Example Applications: examples/Base/IPC/condvar/condvarlocal/src/condvarlocal.cpp Source File

00001 // Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
-00002 // All rights reserved.
-00003 // This component and the accompanying materials are made available
-00004 // under the terms of "Eclipse Public License v1.0"
-00005 // which accompanies this distribution, and is available
-00006 // at the URL "http://www.eclipse.org/legal/epl-v10.html".
-00007 //
-00008 // Initial Contributors:
-00009 // Nokia Corporation - initial contribution.
-00010 //
-00011 // Contributors:
-00012 //
-00013 // Description:
-00014 // Contains the E32Main() function, which executes the example.
-00015 // The example demonstrates the use of local condition variable IPC mechanism. The threads created in the process use this condition variable to co-operate with each other.
-00016 // The example performs the following tasks:
-00017 // - create an object of the CQueue class, which in turn crates a queue of integer tokens
-00018 // - create an object of the CProducer class, which in turn creates the producer thread
-00019 // - create an object of the CConsumer class, which in turn creates the consumer thread
-00020 // - create an object of the CUserInterface class ,which accepts asynchronous key press events from the console.
-00021 // The CUserInterface class provides an interface for the user to interact with the threads created in the example.
-00022 // The CQueue::iCondVar is the local condition varaibale that is used by the two threads to co-operate with each other.
-00023 //
-00024 
-00025 
-00026 
-00035 #include "globals.h"
-00036 #include "queue.h"
-00037 #include "producer.h"
-00038 #include "consumer.h"
-00039 #include "userinterface.h"
-00040 
-00041 LOCAL_D CConsoleBase* console;
-00042 LOCAL_C void DoExampleL();
-00043 LOCAL_C void callExampleL();
-00044 
-00045 LOCAL_C void DoExampleL()
-00046         {
-00047         CActiveScheduler* scheduler = new (ELeave) CActiveScheduler();
-00048         CleanupStack::PushL(scheduler);
-00049         CActiveScheduler::Install(scheduler);
-00050 
-00051         // Create an object of the CQueue class.
-00052         CQueue* tokens = CQueue::NewL();
-00053         CleanupStack::PushL(tokens);
-00054 
-00055         // Print the KTextInvokeProducer string and wait for a key press.
-00056         _LIT(KTextInvokeProducer,"Creating and starting the Producer Thread...[This produces a token every two seconds]\n");
-00057         console->Printf(KTextInvokeProducer);
-00058         _LIT(KTxtPressAnyKeyToContinue,"[press any key to continue]\n");
-00059         console->Printf(KTxtPressAnyKeyToContinue);
-00060         console->Getch();
-00061         // Create an object of the CProducer class.
-00062         CProducer* prod = CProducer::NewL(console,tokens);
-00063         CleanupStack::PushL(prod);
-00064 
-00065         // Print the KTextInvokeConsumer string and wait for a key press.
-00066         _LIT(KTextInvokeConsumer,"Creating and starting the Consumer Thread...[This consumes a token every second]\n");
-00067         console->Printf(KTextInvokeConsumer);
-00068         console->Printf(KTxtPressAnyKeyToContinue);
-00069         console->Getch();
-00070 
-00071         // Create an object of the CConsumer class.
-00072         CConsumer* cons = CConsumer::NewL(console,tokens);
-00073         CleanupStack::PushL(cons);
-00074 
-00075         // Create an object of the CUserInterface class.
-00076         // This handles key press requests from the console.
-00077         CUserInterface* ui = CUserInterface::NewL(console,prod);
-00078         CleanupStack::PushL(ui);
-00079         
-00080         _LIT(KTextStartAS,"Starting the active scheduler...\n");
-00081         console->Printf(KTextStartAS);
-00082         // Issue an asynchronous read request.
-00083         ui->ReadFunc();
-00084         // Start the active scheduler.
-00085         CActiveScheduler::Start();
-00086 
-00087         CleanupStack::PopAndDestroy(5,scheduler);
-00088         }
-00089 
-00090 GLDEF_C TInt E32Main()
-00091     {
-00092         __UHEAP_MARK;
-00093         CTrapCleanup* cleanup=CTrapCleanup::New();
-00094         TRAPD(error,callExampleL());
-00095         delete cleanup;
-00096         __ASSERT_ALWAYS(!error,User::Panic(KTxtEPOC32EX,error));
-00097         __UHEAP_MARKEND;
-00098         return 0;
-00099     }
-00100 
-00101 LOCAL_C void callExampleL()
-00102     {
-00103         console=Console::NewL(KTxtExampleCode,TSize(KConsFullScreen,KConsFullScreen));
-00104         CleanupStack::PushL(console);
-00105         TRAPD(error,DoExampleL());
-00106         if (error)
-00107                 console->Printf(KFormatFailed, error);
-00108         else
-00109                 console->Printf(KTxtOK);
-00110         console->Printf(KTxtPressAnyKey);
-00111         console->Getch();
-00112         CleanupStack::PopAndDestroy();
-00113     }
-