binder机制原理android,转载 Android Binder机制详解（三）

...

//难道是下面两个？

ProcessState::self()->startThreadPool();

IPCThreadState::self()->joinThreadPool();

看看startThreadPool吧

void ProcessState::startThreadPool()

{

...

spawnPooledThread(true);

}

void ProcessState::spawnPooledThread(bool

isMain)

{

sp

t = new PoolThread(isMain);isMain是TRUE

//创建线程池，然后run起来，和java的Thread何其像也。

t->run(buf);

}

PoolThread从Thread类中派生，那么此时会产生一个线程吗？看看PoolThread和Thread的构造吧

PoolThread::PoolThread(bool isMain)

:

mIsMain(isMain)

{

}

Thread::Thread(bool

canCallJava)//canCallJava默认值是true

:mCanCallJava(canCallJava),

mThread(thread_id_t(-1)),

mLock("Thread::mLock"),

mStatus(NO_ERROR),

mExitPending(false),

mRunning(false)

{

}

喔，这个时候还没有创建线程呢。然后调用PoolThread::run，实际调用了基类的run。

status_t Thread::run(const char* name, int32_t

priority, size_t stack)

{

bool res;

if

(mCanCallJava) {

res

= createThreadEtc(_threadLoop,//线程函数是_threadLoop

this,

name, priority, stack, &mThread);

}

//终于，在run函数中，创建线程了。从此

主线程执行

IPCThreadState::self()->joinThreadPool();

新开的线程执行_threadLoop

我们先看看_threadLoop

int Thread::_threadLoop(void* user)

{

Thread*

const self =

static_cast(user);

sp

strong(self->mHoldSelf);

wp

weak(strong);

self->mHoldSelf.clear();

do

{

...

if

(result &&

!self->mExitPending) {

result

= self->threadLoop();哇塞，调用自己的threadLoop

}

}

我们是PoolThread对象，所以调用PoolThread的threadLoop函数

virtual bool PoolThread ::threadLoop()

{

//mIsMain为true。

//而且注意，这是一个新的线程，所以必然会创建一个

新的IPCThreadState对象(记得线程本地存储吗？TLS)，然后

IPCThreadState::self()->joinThreadPool(mIsMain);

return

false;

}

主线程和工作线程都调用了joinThreadPool，看看这个干嘛了！

void IPCThreadState::joinThreadPool(bool

isMain)

{

mOut.writeInt32(isMain

? BC_ENTER_LOOPER : BC_REGISTER_LOOPER);

status_t

result;

do

{

int32_t

cmd;

result

= talkWithDriver();

result

= executeCommand(cmd);

}

}

while (result != -ECONNREFUSED &&

result != -EBADF);

mOut.writeInt32(BC_EXIT_LOOPER);

talkWithDriver(false);

}

看到没？有loop了，但是好像是有两个线程都执行了这个啊！这里有两个消息循环？

下面看看executeCommand

status_t IPCThreadState::executeCommand(int32_t

cmd)

{

BBinder* obj;

RefBase::weakref_type*

refs;

status_t

result = NO_ERROR;

case BR_TRANSACTION:

{

binder_transaction_data

tr;

result

= mIn.read(&tr, sizeof(tr));

//来了一个命令，解析成BR_TRANSACTION,然后读取后续的信息

Parcel

reply;

if

(tr.target.ptr) {

//这里用的是BBinder。

sp

b((BBinder*)tr.cookie);

const

status_t error = b->transact(tr.code, buffer,

&reply, 0);

}

让我们看看BBinder的transact函数干嘛了

status_t BBinder::transact(

uint32_t

code, const Parcel& data, Parcel* reply, uint32_t

flags)

{

就是调用自己的onTransact函数嘛

err = onTransact(code, data, reply,

flags);

return

err;

}