TB10.1 Example Applications: examples/Base/ThreadsAndProcesses/Rendezvous/ThreadRendezvous.cpp Source File

00001 // Copyright (c) 2007-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 // Example to demonstrate the use of Rendezvous() with threads 
+00015 //
+00016 
+00017 #include "CommonFramework.h"
+00018 #include <e32math.h>
+00019 
+00020 //
+00021 // Common literal text
+00022 //
+00023 
+00024 
+00025 _LIT(KMsgMyThreadName, "MyThread");
+00026 _LIT(KMsgStartThread, "Start thread\n");
+00027 _LIT(KMsgThreadRendezvousReached,"Thread rendezvous reached\n");
+00028 _LIT(KMsgEndOfTest,"End of test\n");
+00029 _LIT(KMsgSomethingIsWrong, "Something is wrong\n");
+00030 _LIT(KMsgCreateThreadFailed, "Create thread failed\n");
+00031 
+00032 //Define
+00033 const TInt KHeapSize = 0x2000;
+00034 
+00035 //************************************************************
+00036 // Declare Thread functions
+00037 //************************************************************
+00038 TInt MyThread(TAny* aParameter)
+00039         {
+00040                 // simulate some processing
+00041         User::After((TInt)aParameter);          
+00042                         
+00043                         // signal Rendezvous
+00044         RThread::Rendezvous(KErrNone);
+00045         
+00046                 // simulate some processing
+00047         User::After((TInt)aParameter);          
+00048         
+00049         return(KErrNone);
+00050         }
+00051 
+00052 //************************************************************
+00053 // Main example code function
+00054 //************************************************************
+00055 LOCAL_C void doExampleL()
+00056         {                                 
+00057                 // create threads to wait for
+00058         RThread thread;
+00059 
+00060                 // indicate completion status
+00061         TRequestStatus myThreadRendezvousStatus;
+00062 
+00063                 // pass 500 as the parameter to MyThread                
+00064         TInt r=thread.Create(KMsgMyThreadName, MyThread, KDefaultStackSize, KHeapSize,KHeapSize,(TAny*) 2000000, EOwnerThread); 
+00065         if (r!=KErrNone)
+00066                 {       
+00067                 console->Printf(KMsgCreateThreadFailed);
+00068                 return;
+00069                 }
+00070                 // create rendezvous
+00071         thread.Rendezvous(myThreadRendezvousStatus);
+00072 
+00073                 //EXCECUTE THREAD!
+00074         console->Printf(KMsgStartThread);                                       
+00075         thread.Resume();
+00076 
+00077         User::WaitForRequest(myThreadRendezvousStatus);
+00078         if(myThreadRendezvousStatus==KErrNone)
+00079                 {
+00080                 console->Printf(KMsgThreadRendezvousReached);
+00081                 }
+00082                 else
+00083                 {
+00084                 console->Printf(KMsgSomethingIsWrong);  
+00085                 }       
+00086                 
+00087         thread.Close();
+00088         console->Printf(KMsgEndOfTest);         
+00089         
+00090         }
+00091 
+00092 
+00093         
+00094 
+00095 
+00096 
+00097         
+00098         
+