原文地址：http://blog.csdn.net/suyouxin/archive/2005/01/06/242759.aspx
symbian中活動服務對象的一些簡單的使用
對symbain的學習已經又幾個月了,今天來寫寫自己的一些活動服務對象使用方法.
symbian官方推薦使用活動服務對象(CActive)來代替多線程的使用,我想這個道理是很明了的,在手機這樣的小內存設備里,運行多線程的程序是非常耗資源的,為了節約資源,symbian提供了一個活動服務對象的框架,允許把程序里并發執行對象(其實不是并發,不過宏觀上看來是)放在一個線程里面執行,這些并發工作的對象就通過活動規劃器(ActiveScheduler)來進行管理.
關于這兩個東西的介紹,網上有一大堆的文檔,我就不在這里廢話了,如何使用呢?這里我先舉一個簡單的計數器的例子.我選擇寫一個exe的程序,也就是說程序是以E32Main為入口的.
GLDEF_C TInt E32Main()
{
CTrapCleanup* cleanup=CTrapCleanup::New();
TRAPD(error,callInstanceL());
if (error != KErrNone){
printf("get error %d\r\n", error);
}
delete cleanup;
return 0;
}
以上的內容是每一個exe文件都應該做的,CTrapCleanup* cleanup=CTrapCleanup::New()建立一個清除堆棧,以便程序在異常退出的時候把清除堆棧里面的資源都釋放掉.當然你也可以加上堆檢測宏,這里我就不多說了.TRAPD是symbian里面經常使用的宏,功能類似于try,第一個參數是讓定義一個錯誤返回值變量的名字, 后面就是可能有異常的你寫的函數.當這個函數異常時,程序不會crash, 你可以得到異常的原因.可以參考nokia論壇上的一些關于這些使用的文檔.
接下來是vcallInstanceL函數,在這個函數里面我來建立ActiveScheduler.
LOCAL_C void callInstanceL()
{
CActiveScheduler* scheduler = new(ELeave) CActiveScheduler();
CleanupStack::PushL(scheduler);
CActiveScheduler::Install(scheduler);
TRAPD(error,doInstanceL());
if(error) {
printf("error code=%d\r\n",error);
}
else {
printf("OK!\r\n[press any key]");
}
CleanupStack::PopAndDestroy(scheduler);
}
這段程序很簡單就是創建一個活動規劃器,并壓入清除棧,然后安裝活動規劃器,這樣就可以用了.再執行真正的實例函數,最后出棧銷毀.doinstanceL我們放到最后來寫,現在來構造我們的活動計數器對象.
class TimeCount : public CActive
{
public :
static TimeCount* NewLC(); // 構造函數
~TimeCount();
void StartL(); // 計數開始
void ConstructL();
void RunL(); // 延時事件到達以后的處理函數
void DoCancel(); // 取消請求提交
void setDelayTime(int delayTime);
private:
TimeCount();
RTimer iTimer; // 定時器
int iTimeCount; // 計數器
int mTime; // 計數間隔時間 單位秒
};
TimeCount::TimeCount()
: CActive(0) // 這里可以設置活動對象的優先級
{
// 把自己加入活動規劃器
CActiveScheduler::Add(this);
}
TimeCount* TimeCount::NewLC()
{
TimeCount* result = new (ELeave) TimeCount();
CleanupStack::PushL( result );
result->ConstructL();
return result;
}
void TimeCount::DoCancel(void)
{
iTimer.Cancel();
}
void TimeCount::setDelayTime(int mTime)
{
DelayTime = mTime;
}
TimeCount::~TimeCount()
{
Cancel();
iTimer.Close();
}
void TimeCount::StartL()
{
// 設定定時器狀態為每隔mTime秒鐘狀態完成一次
iTimer.After(iStatus, 10000 * 100 * mTime);
// 提交異步請求
SetActive();
}
void TimeCount::ConstructL()
{
// 初始化計數器和定時器
iTimeCount = 0;
User::LeaveIfError(iTimer.CreateLocal());
}
void TimeCount::RunL()
{
// 計數器+1以后繼續提交延時請求事件
printf("The Count is ->>%d", iTimeCount++);
StartL();
}
每一個活動服務對象都有一個iStatus來標識當前對象的狀態.在這里我們把iStatus設定為iTimer.After(iStatus, 10000 * 100 * mTime);也就是定時器定時mTime秒鐘以后iStatus發生改變,這個時候活動規劃器會收到這個狀態的改變,從而調用相應活動對象的處理函數,也就是RunL函數.在RunL函數里面進行計數和輸出,然后調用startL重新設置定時器和對象狀態,再提交給活動規劃器.這樣mTime秒鐘以后活動規劃器會再次調用RunL函數.一直這樣重復,這樣就達到了計數器的效果.
最后我們來寫doinstanceL函數
LOCAL_C void doInstanceL()
{
TimeCount* timeCount = TimeCount::NewLC();
// 每隔一秒鐘打印一次
TimeCount->setDelayTime(1);
TimeCount->StartL();
CActiveScheduler::Start();
CleanupStack::PopAndDestroy(1);
}
創建好對象以后,加上CActiveScheduler::Start()程序就開始運行了,這句話告訴活動規劃器該等待對象的狀態的改變了,在這里就是timeCount的iStatus的改變.等iStatus改變并調用了RunL以后,繼續等待iStstus的改變,這樣我們使用活動對象的計數器就能夠通過消息驅動運行起來了.
這里的CActiveScheduler只管理了一個CActive對象,就是timeCount,可以用類似的方法實現多個CActive,并且都加入CActiveScheduler,CActiveScheduler將會等待所有加入它的CActive的狀態的改變,其中有一個的狀態改變就會去執行對應的活動對象的處理函數,當狀態同時發生的時候,會通過對象的優先級來決定先調用誰的RunL函數.CActiveScheduler也是非搶占式的,當一個RunL函數還沒有執行完的時候,如果另一個CActive的狀態改變,會等待RunL執行完以后再執行另一個CActive的處理函數.
用起來還算簡單吧?.
本文來自CSDN博客，轉載請標明出處：http://blog.csdn.net/suyouxin/archive/2005/01/06/242759.aspx
原文地址：http://blog.csdn.net/alex_hua/archive/2008/07/10/2633137.aspx
由于做工程的移植工作，需要移植代碼到Symbian平臺上，但之前代碼的架構與Symbian平臺看起來是有沖突，體現在之前代碼中有一個獨立線程用來做事件驅動、分發，然后在事件回調中完成自己的邏輯（包括異步請求），該線程是用
while(1)
{
getevent();
dispatchevent()
}
來實現。但在Symbian平臺上，所有的異步方法的偵測是通過CActiveScheduler.Start()完成，且該方法實際上就是一個死循環。這樣看起來，在同一個線程中，是不可能有兩個死循環存在的，這個移植是不能完成的，除非修改代碼架構。
這個問題確實困擾了很久，呵呵，因為是一個人開發，確實沒有人可以幫忙出點主義，腦子也死了，想不開了。現在終于有眉目了，基本可以解決該問題，途徑就是理解活動對象和活動規劃器的原理，靈活應用這對活寶！
之前一直想著，為了能偵測到異步請求是否完成，CActiveScheduler.Start()這個方法必須在線程的初始就調用，其實可以不這樣，CActiveScheduler.Start()在線程的任何地方隨時可以調用，且CActiveScheduler起來后，還是可以偵測到“很久”以前就完成的異步請求。例子如下：
/* ============================================================================
Name : NewClassTest.h Author : Alex Version : 1.0 Copyright : su-fun Description : CNewClassTest declaration ============================================================================ */
#ifndef NEWCLASSTEST_H
#define NEWCLASSTEST_H
#include <e32base.h>
// For CActive, link against: euser.lib
#include <e32std.h>
//For RTimer, link against: euser.lib
class CNewClassTest : public CActive
{
public:
// Cancel and destroy
~CNewClassTest();
// Two-phased constructor.
static CNewClassTest* NewL();
// Two-phased constructor.
static CNewClassTest* NewLC();
public:
// New functions
// Function for making the initial request
void StartL(TInt aState, TTimeIntervalMicroSeconds32 aDelay);
private:
// C++ constructor
CNewClassTest();
// Second-phase constructor
void ConstructL();
private:
// From CActive // Handle completion
void RunL();
// How to cancel me
void DoCancel();
// Override to handle leaves from RunL(). Default implementation causes
// the active scheduler to panic.
TInt RunError(TInt aError);
public:
enum TNewClassTestState
{
EUninitialized=12, // Uninitialized
EInitialized=22, // Initalized
EError=32 // Error condition
};
private:
TInt iState; // State of the active object
RTimer iTimer; // Provides async timing service
};
#endif // NEWCLASSTEST_H
/* ============================================================================
Name : NewClassTest.cpp Author : Alex Version : 1.0 Copyright : su-fun Description : CNewClassTest implementation ============================================================================ */
#include "NewClassTest.h"
CNewClassTest::CNewClassTest() : CActive(EPriorityStandard) // Standard priority
{
}
CNewClassTest* CNewClassTest::NewLC()
{
CNewClassTest* self = new ( ELeave ) CNewClassTest();
CleanupStack::PushL(self);
self->ConstructL(); return self;
}
CNewClassTest* CNewClassTest::NewL()
{
CNewClassTest* self = CNewClassTest::NewLC();
CleanupStack::Pop(); // self;
return self;
}
void CNewClassTest::ConstructL()
{
User::LeaveIfError(iTimer.CreateLocal() ); // Initialize timer
CActiveScheduler::Add( this); // Add to scheduler
}
CNewClassTest::~CNewClassTest()
{
Cancel(); // Cancel any request, if outstanding
iTimer.Close(); // Destroy the RTimer object
// Delete instance variables if any
}
void CNewClassTest::DoCancel()
{
iTimer.Cancel();
}
void CNewClassTest::StartL(TInt aState, TTimeIntervalMicroSeconds32 aDelay)
{
Cancel(); // Cancel any request, just to be sure
iState = aState;
iTimer.After(iStatus, aDelay); // Set for later
SetActive(); // Tell scheduler a request is active
}
void CNewClassTest::RunL()
{
if (iState == EUninitialized)
{
// older timer event, 當CActiveScheduler::Start()后，程序先到達這里
iState = 10;
}
else if(iState == EInitialized)
{
//// new timer event
iState = 201;
CActiveScheduler::Stop();
}
}
TInt CNewClassTest::RunError(TInt aError)
{
return aError;
}
// 測試代碼
// TInt ThreadEntry(TAny *arg), 用戶線程的入口函數,省略了一些必要的初始化
TInt ThreadEntry(TAny *arg)
{
CNewClassTest *obj1 = CNewClassTest::NewL();
CNewClassTest *obj2 = CNewClassTest::NewL();
obj-1>StartL(CNewClassTest::EUninitialized,TTimeIntervalMicroSeconds32(1000000)); //1(s)
User::After(5000000); // sleep 5(s)
obj2->StartL(CNewClassTest::EInitialized,TTimeIntervalMicroSeconds32(20000)); //20(ms)
CActiveScheduler::Start();
delete obj1;
delete obj2;
}
以上代碼演示了如何靈活使用CActiveScheduler::Start()，至于具體的實現上，還需要調整一下，CActiveScheduler::Start()的必須還要同時啟動一個超時定時器，當在設定的超時時間內沒有任何異步時間完成，則在超時AO內停止活動規劃器CActiveScheduler::Stop()，這樣等待下一個循環到來再啟動活動規劃器。此時可繼續執行被CActiveScheduler::Start()方法掛起的語句和方法。
總結：
1. 可以解決移植代碼中出現的上述情況
2. 異步事件的完成檢測有時延
3. 因為是異步事件，對于一定的時延，還是可以接受的
本文來自CSDN博客，轉載請標明出處：http://blog.csdn.net/alex_hua/archive/2008/07/10/2633137.aspx
posted on 2010-03-24 17:02
漂漂 閱讀(413)
評論(0) 編輯 收藏 引用 所屬分類:
symbian開發