用AI赚第一桶💰低成本搭建一套AI赚钱工具,源码可二开。 广告
重要的内容都已讲过了,现在就剩下最后两个函数startThreadPool()和joinThreadPool没有分析了。它们就太简单了不是? 1. 创造劳动力——startThreadPool() startThreadPool()的实现,如下面的代码所示: **ProcessState.cpp** ~~~ //太简单,没什么好说的 void ProcessState::startThreadPool() { AutoMutex _l(mLock); //如果要是已经startThreadPool的话,这个函数就没有什么实质作用了 if(!mThreadPoolStarted) { mThreadPoolStarted = true; spawnPooledThread(true); //注意,传进去的参数是true } } ~~~ 上面的spawnPooledThread()函数的实现,如下所示: **ProcessState.cpp** ~~~ void ProcessState::spawnPooledThread(bool isMain) { //注意,isMain参数是true。 if(mThreadPoolStarted) { int32_t s = android_atomic_add(1, &mThreadPoolSeq); char buf[32]; sprintf(buf, "Binder Thread #%d", s); sp<Thread> t = new PoolThread(isMain); t->run(buf); } } ~~~ PoolThread是在IPCThreadState中定义的一个Thread子类,它的实现,如下所示: **IPCThreadState.h::PoolThread类** ~~~ class PoolThread : public Thread { public: PoolThread(bool isMain) :mIsMain(isMain){} protected: virtualbool threadLoop() { //线程函数如此简单,不过是在这个新线程中又创建了一个IPCThreadState。 // 你还记得它是每个伙计都有一个的吗? IPCThreadState::self()->joinThreadPool(mIsMain); return false; } const boolmIsMain; }; ~~~ 2. 万众归一——joinThreadPool 还需要看看IPCThreadState的joinThreadPool的实现,因为新创建的线程也会调用这个函数,具体代码如下所示: **IPCThreadState.cpp** ~~~ void IPCThreadState::joinThreadPool(bool isMain) { //注意,如果isMain为true,我们需要循环处理。把请求信息写到mOut中,待会儿一起发出去 mOut.writeInt32(isMain ? BC_ENTER_LOOPER : BC_REGISTER_LOOPER); androidSetThreadSchedulingGroup(mMyThreadId, ANDROID_TGROUP_DEFAULT); status_tresult; do { int32_t cmd; if(mIn.dataPosition() >= mIn.dataSize()) { size_t numPending = mPendingWeakDerefs.size(); if (numPending > 0) { for (size_t i = 0; i < numPending; i++) { RefBase::weakref_type* refs = mPendingWeakDerefs[i]; refs->decWeak(mProcess.get()); } mPendingWeakDerefs.clear(); } //处理已经死亡的BBinder对象 numPending = mPendingStrongDerefs.size(); if (numPending > 0) { for (size_t i = 0; i < numPending; i++) { BBinder* obj = mPendingStrongDerefs[i]; obj->decStrong(mProcess.get()); } mPendingStrongDerefs.clear(); } } // 发送命令,读取请求 result = talkWithDriver(); if(result >= NO_ERROR) { size_t IN = mIn.dataAvail(); if (IN < sizeof(int32_t)) continue; cmd = mIn.readInt32(); result= executeCommand(cmd); //处理消息 } ...... } while(result != -ECONNREFUSED && result != -EBADF); mOut.writeInt32(BC_EXIT_LOOPER); talkWithDriver(false); } ~~~ 原来,我们的两个伙计在talkWithDriver,它们希望能从Binder设备那里找到点可做的事情。 3. 有几个线程在服务 到底有多少个线程在为Service服务呢?目前看来是两个: - startThreadPool中新启动的线程通过joinThreadPool读取Binder设备,查看是否有请求。 - 主线程也调用joinThreadPool读取Binder设备,查看是否有请求。看来,binder设备是支持多线程操作的,其中一定是做了同步方面的工作。 mediaserver这个进程一共注册了4个服务,繁忙的时候,两个线程会不会显得有点少呢?另外,如果实现的服务负担不是很重,完全可以不调用startThreadPool创建新的线程,使用主线程即可胜任。