| /frameworks/base/services/core/java/com/android/server/wm/ |
| D | ViewServer.java | 76 private ExecutorService mThreadPool; field in ViewServer
109 mThreadPool = Executors.newFixedThreadPool(VIEW_SERVER_MAX_CONNECTIONS); in start()
129 if (mThreadPool != null) { in stop()
131 mThreadPool.shutdownNow(); in stop()
136 mThreadPool = null; in stop()
170 if (mThreadPool != null) { in run()
171 mThreadPool.submit(new ViewServerWorker(client)); in run()
|
| /frameworks/base/media/jni/soundpool/ |
| D | SoundDecoder.cpp | 37 mThreadPool = std::make_unique<ThreadPool>( in SoundDecoder()
58 mThreadPool->quit(); in quit()
110 if (pendingSounds > mThreadPool->getActiveThreadCount()) { in loadSound()
111 const int32_t id = mThreadPool->launch([this](int32_t id) { run(id); }); in loadSound()
|
| D | StreamManager.cpp | 126 mThreadPool = std::make_unique<ThreadPool>(
143 mThreadPool->quit(); in ~StreamManager()
271 const int32_t id = mThreadPool->launch([this](int32_t id) { run(id); }); in queueForPlay()
301 const int32_t id = mThreadPool->launch([this](int32_t id) { run(id); }); in moveToRestartQueue()
|
| D | SoundDecoder.h | 41 std::unique_ptr<ThreadPool> mThreadPool; // set in constructor, has own lock variable
|
| D | StreamManager.h | 425 (mThreadPool->getActiveThreadCount() == 0 in needMoreThreads_l()
428 > (ptrdiff_t)mThreadPool->getActiveThreadCount()); in needMoreThreads_l()
452 std::unique_ptr<ThreadPool> mThreadPool; // locked internally variable
|
| /frameworks/wilhelm/src/objects/ |
| D | CEngine.cpp | 69 result = ThreadPool_init(&thiz->mThreadPool, 0, 0); in CEngine_Realize()
138 ThreadPool_deinit(&thiz->mThreadPool); in CEngine_Destroy()
|
| /frameworks/av/media/libstagefright/rtsp/fuzzer/ |
| D | rtsp_connection_fuzzer.cpp | 84 for (auto& thread : mThreadPool) { in ~RTSPConnectionFuzzer()
114 std::vector<std::thread> mThreadPool; member in RTSPConnectionFuzzer
348 while (mFdp.remaining_bytes() && mThreadPool.size() < kMaxThreads) { in process()
350 mThreadPool.push_back(std::thread(&RTSPConnectionFuzzer::acceptConnection, this)); in process()
|
| /frameworks/wilhelm/src/ |
| D | sles_allinclusive.h | 459 ThreadPool_add_ppi(&(object)->mObject.mEngine->mThreadPool, \
462 ThreadPool_add_ppii(&(object)->mObject.mEngine->mThreadPool, \
465 ThreadPool_add_piipp(&(object)->mObject.mEngine->mThreadPool, \
|
| D | entry.cpp | 149 memset(&thiz->mThreadPool, 0, sizeof(ThreadPool)); in liCreateEngine()
|
| D | classes.h | 200 ThreadPool mThreadPool; // for asynchronous operations member
|
| /frameworks/av/services/audioflinger/afutils/ |
| D | NBAIO_Tee.cpp | 87 : mThreadPool(pool) in AudioFileHandler()
176 } mThreadPool; member in android::AudioFileHandler
265 if (mThreadPool.launch(std::string("create ") + filename, in create()
324 (void)mThreadPool.launch( in setDirectory()
|
| /frameworks/wilhelm/src/itf/ |
| D | IDynamicInterfaceManagement.cpp | 138 result = ThreadPool_add_ppi(&thisObject->mEngine->mThreadPool, HandleAdd, thiz, in IDynamicInterfaceManagement_AddInterface()
386 result = ThreadPool_add_ppi(&thisObject->mEngine->mThreadPool, HandleResume, in IDynamicInterfaceManagement_ResumeInterface()
|
| D | IObject.cpp | 125 result = ThreadPool_add_ppi(&thiz->mEngine->mThreadPool, HandleRealize, thiz, NULL, 0); in IObject_Realize()
253 result = ThreadPool_add_ppi(&thiz->mEngine->mThreadPool, HandleResume, thiz, NULL, 0); in IObject_Resume()
|