| /aosp_15_r20/external/cronet/third_party/apache-portable-runtime/src/threadproc/os2/ |
| H A D | thread.c | 27 APR_DECLARE(apr_status_t) apr_threadattr_create(apr_threadattr_t **new, apr_pool_t *pool) in apr_threadattr_create()
71 apr_thread_t *thread = (apr_thread_t *)arg; in apr_thread_begin() local
79 apr_pool_t *pool) in apr_thread_create()
82 apr_thread_t *thread; in apr_thread_create() local
184 apr_pool_t *pool) in apr_os_thread_put()
203 APR_DECLARE(apr_status_t) apr_thread_data_get(void **data, const char *key, apr_thread_t *thread) in apr_thread_data_get()
212 apr_thread_t *thread) in apr_thread_data_set()
217 APR_POOL_IMPLEMENT_ACCESSOR(thread) in APR_POOL_IMPLEMENT_ACCESSOR() argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/quiche/deps/boringssl/src/crypto/pool/ |
| D | pool_test.cc | 49 bssl::UniquePtr<CRYPTO_BUFFER_POOL> pool(CRYPTO_BUFFER_POOL_new()); in TEST() local
66 bssl::UniquePtr<CRYPTO_BUFFER_POOL> pool(CRYPTO_BUFFER_POOL_new()); in TEST() local
74 std::thread thread([&] { in TEST() local
100 std::thread thread([&] { buf_ref = bssl::UpRef(buf); }); in TEST() local
114 std::thread thread([&] { in TEST() local
128 std::thread thread([&] { buf.reset(); }); in TEST() local
142 std::thread thread([&] { buf.reset(); }); in TEST() local
|
| /aosp_15_r20/external/rust/crates/quiche/deps/boringssl/src/crypto/pool/ |
| D | pool_test.cc | 49 bssl::UniquePtr<CRYPTO_BUFFER_POOL> pool(CRYPTO_BUFFER_POOL_new()); in TEST() local
66 bssl::UniquePtr<CRYPTO_BUFFER_POOL> pool(CRYPTO_BUFFER_POOL_new()); in TEST() local
74 std::thread thread([&] { in TEST() local
100 std::thread thread([&] { buf_ref = bssl::UpRef(buf); }); in TEST() local
114 std::thread thread([&] { in TEST() local
128 std::thread thread([&] { buf.reset(); }); in TEST() local
142 std::thread thread([&] { buf.reset(); }); in TEST() local
|
| /aosp_15_r20/external/boringssl/src/crypto/pool/ |
| H A D | pool_test.cc | 66 bssl::UniquePtr<CRYPTO_BUFFER_POOL> pool(CRYPTO_BUFFER_POOL_new()); in TEST() local
130 bssl::UniquePtr<CRYPTO_BUFFER_POOL> pool(CRYPTO_BUFFER_POOL_new()); in TEST() local
138 std::thread thread([&] { in TEST() local
164 std::thread thread([&] { buf_ref = bssl::UpRef(buf); }); in TEST() local
178 std::thread thread([&] { in TEST() local
192 std::thread thread([&] { buf.reset(); }); in TEST() local
206 std::thread thread([&] { buf.reset(); }); in TEST() local
|
| /aosp_15_r20/external/cronet/third_party/boringssl/src/crypto/pool/ |
| H A D | pool_test.cc | 66 bssl::UniquePtr<CRYPTO_BUFFER_POOL> pool(CRYPTO_BUFFER_POOL_new()); in TEST() local
130 bssl::UniquePtr<CRYPTO_BUFFER_POOL> pool(CRYPTO_BUFFER_POOL_new()); in TEST() local
138 std::thread thread([&] { in TEST() local
164 std::thread thread([&] { buf_ref = bssl::UpRef(buf); }); in TEST() local
178 std::thread thread([&] { in TEST() local
192 std::thread thread([&] { buf.reset(); }); in TEST() local
206 std::thread thread([&] { buf.reset(); }); in TEST() local
|
| /aosp_15_r20/external/cronet/third_party/apache-portable-runtime/src/threadproc/unix/ |
| H A D | thread.c | 41 apr_pool_t *pool) in apr_threadattr_create()
141 apr_thread_t *thread = (apr_thread_t*)opaque; local
149 apr_pool_t *pool)
267 apr_thread_t *thread)
274 apr_thread_t *thread)
288 apr_pool_t *pool)
|
| /aosp_15_r20/external/cronet/third_party/apache-portable-runtime/src/threadproc/netware/ |
| H A D | thread.c | 25 apr_pool_t *pool) in apr_threadattr_create()
77 apr_pool_t *pool) in apr_thread_create()
187 apr_thread_t *thread) in apr_thread_data_get()
200 apr_thread_t *thread) in apr_thread_data_set()
223 apr_pool_t *pool) in apr_os_thread_put()
|
| /aosp_15_r20/external/cronet/third_party/apache-portable-runtime/src/threadproc/win32/ |
| H A D | thread.c | 32 apr_pool_t *pool) in apr_threadattr_create()
85 void *data, apr_pool_t *pool) in apr_thread_create()
197 apr_thread_t *thread) in apr_thread_data_get()
204 apr_thread_t *thread) in apr_thread_data_set()
242 apr_pool_t *pool) in apr_os_thread_put()
|
| /aosp_15_r20/external/cronet/third_party/apache-portable-runtime/src/threadproc/beos/ |
| H A D | thread.c | 20 APR_DECLARE(apr_status_t) apr_threadattr_create(apr_threadattr_t **new, apr_pool_t *pool) in apr_threadattr_create()
73 apr_pool_t *pool) in apr_thread_create()
165 APR_DECLARE(apr_status_t) apr_thread_data_get(void **data, const char *key, apr_thread_t *thread) in apr_thread_data_get()
172 apr_thread_t *thread) in apr_thread_data_set()
184 apr_pool_t *pool) in apr_os_thread_put()
|
| /aosp_15_r20/frameworks/base/core/tests/coretests/src/android/database/sqlite/ |
| H A D | SQLiteConnectionPoolTest.java | 74 HandlerThread thread = new HandlerThread("test-close-idle-connections-thread"); in testCloseIdleConnections() local
77 SQLiteConnectionPool pool = SQLiteConnectionPool.open(mTestConf); in testCloseIdleConnections() local
96 HandlerThread thread = new HandlerThread("test-close-idle-connections-thread"); in testNonprimaryConnectionPoolRecycling() local
98 SQLiteConnectionPool pool = SQLiteConnectionPool.open(mTestConf); in testNonprimaryConnectionPoolRecycling() local
|
| /aosp_15_r20/frameworks/av/media/codec2/components/vpx/ |
| H A D | C2SoftVpxDec.cpp | 485 sp<ConverterThread> thread(new ConverterThread(mQueue)); in initDecoder() local
504 for (const sp<ConverterThread> &thread : mConverterThreads) { in destroyDecoder() local
510 for (const sp<ConverterThread> &thread : mConverterThreads) { in destroyDecoder() local
583 const std::shared_ptr<C2BlockPool> &pool) { in process()
702 const std::shared_ptr<C2BlockPool> &pool, in outputBuffer()
864 const std::shared_ptr<C2BlockPool> &pool, in drainInternal()
887 const std::shared_ptr<C2BlockPool> &pool) { in drain()
|
| /aosp_15_r20/external/webrtc/rtc_base/ |
| H A D | thread.cc | 147 void ThreadManager::RemoveFromSendGraph(Thread* thread) { in RemoveFromSendGraph()
225 Thread* thread = manager->CurrentThread(); in Current() local
242 void ThreadManager::SetCurrentThreadInternal(Thread* thread) { in SetCurrentThreadInternal()
254 void ThreadManager::SetCurrentThreadInternal(Thread* thread) { in SetCurrentThreadInternal()
259 void ThreadManager::SetCurrentThread(Thread* thread) { in SetCurrentThread()
283 void rtc::ThreadManager::ChangeCurrentThreadForTest(rtc::Thread* thread) { in ChangeCurrentThreadForTest()
720 Thread* thread = static_cast<Thread*>(pv); in PreRun() local
724 ScopedAutoReleasePool pool; in PreRun() local
842 void Thread::AllowInvokesToThread(Thread* thread) { in PreRun()
885 for (const auto* thread : allowed_threads_) { in PreRun() local
[all …]
|
| /aosp_15_r20/external/libgav1/src/utils/ |
| H A D | threadpool.cc | 82 std::unique_ptr<ThreadPool> pool(new (std::nothrow) ThreadPool( in Create() local
158 ThreadPool::WorkerThread::WorkerThread(ThreadPool* pool) : pool_(pool) {} in WorkerThread()
182 auto* thread = static_cast<WorkerThread*>(arg); in ThreadBody() local
200 auto* thread = static_cast<WorkerThread*>(arg); in ThreadBody() local
|
| /aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| H A D | DelayJvmTest.kt | 15 var thread: Thread? = null in <lambda>() variable
16 val pool = Executors.newFixedThreadPool(1) { runnable -> in <lambda>() constant
55 …class CustomInterceptor(val pool: Executor) : AbstractCoroutineContextElement(ContinuationIntercep… in <lambda>() constant in kotlinx.coroutines.DelayJvmTest.CustomInterceptor
60 class Wrapper<T>(val pool: Executor, private val cont: Continuation<T>) : Continuation<T> { in <lambda>() constant in kotlinx.coroutines.DelayJvmTest.Wrapper
|
| /aosp_15_r20/libcore/ojluni/src/test/java/util/concurrent/tck/ |
| H A D | JSR166TestCase.java | 964 Thread thread = survivors[i]; in checkForkJoinPoolThreadLeaks() local
1134 private final ExecutorService pool; field in JSR166TestCase.PoolCleaner
1135 public PoolCleaner(ExecutorService pool) { this.pool = pool; } in PoolCleaner()
1144 public PoolCleanerWithReleaser(ExecutorService pool, Runnable releaser) { in PoolCleanerWithReleaser()
1157 PoolCleaner cleaner(ExecutorService pool) { in cleaner()
1161 PoolCleaner cleaner(ExecutorService pool, Runnable releaser) { in cleaner()
1165 PoolCleaner cleaner(ExecutorService pool, CountDownLatch latch) { in cleaner()
|
| /aosp_15_r20/external/cronet/base/threading/ |
| H A D | simple_thread_unittest.cc | 139 DelegateSimpleThread thread(&runner, "int_setter"); in TEST() local
160 DelegateSimpleThread thread(&runner, "event_waiter"); in TEST() local
174 DelegateSimpleThread thread(&runner, "non_joinable", options); in TEST() local
194 std::unique_ptr<DelegateSimpleThread> thread( in TEST() local
212 DelegateSimpleThreadPool pool("seq_runner", 10); in TEST() local
|
| /aosp_15_r20/external/libchrome/base/threading/ |
| H A D | simple_thread_unittest.cc | 131 DelegateSimpleThread thread(&runner, "int_setter"); in TEST() local
152 DelegateSimpleThread thread(&runner, "event_waiter"); in TEST() local
166 DelegateSimpleThread thread(&runner, "non_joinable", options); in TEST() local
186 std::unique_ptr<DelegateSimpleThread> thread( in TEST() local
204 DelegateSimpleThreadPool pool("seq_runner", 10); in TEST() local
|
| /aosp_15_r20/libcore/jsr166-tests/src/test/java/jsr166/ |
| H A D | JSR166TestCase.java | 682 Thread thread = survivors[i]; in checkForkJoinPoolThreadLeaks() local
855 private final ExecutorService pool; field in JSR166TestCase.PoolCleaner
856 public PoolCleaner(ExecutorService pool) { this.pool = pool; } in PoolCleaner()
865 public PoolCleanerWithReleaser(ExecutorService pool, Runnable releaser) { in PoolCleanerWithReleaser()
878 PoolCleaner cleaner(ExecutorService pool) { in cleaner()
882 PoolCleaner cleaner(ExecutorService pool, Runnable releaser) { in cleaner()
886 PoolCleaner cleaner(ExecutorService pool, CountDownLatch latch) { in cleaner()
|
| /aosp_15_r20/external/mesa3d/src/intel/vulkan/tests/ |
| H A D | block_pool_no_free.c | 34 pthread_t thread; member
36 struct anv_block_pool *pool; member
108 struct anv_block_pool pool; in run_test() local
|
| /aosp_15_r20/external/mesa3d/src/intel/vulkan_hasvk/tests/ |
| H A D | block_pool_no_free.c | 34 pthread_t thread; member
36 struct anv_block_pool *pool; member
117 struct anv_block_pool pool; in run_test() local
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/lib/core/ |
| H A D | threadpool_test.cc | 30 namespace thread { namespace
37 ThreadPool pool(Env::Default(), "test", num_threads); in TEST() local
51 ThreadPool pool(Env::Default(), "test", num_threads); in TEST() local
270 ThreadPool pool(Env::Default(), "test", num_threads); in TEST() local
296 ThreadPool pool(Env::Default(), "test", num_threads); in TEST() local
325 ThreadPool pool(Env::Default(), "test", num_threads); in TEST() local
360 ThreadPool pool(Env::Default(), "test", kNumThreads); in TEST() local
377 ThreadPool pool(Env::Default(), "test", kNumThreads); in BM_Sequential() local
401 ThreadPool pool(Env::Default(), "test", kNumThreads); in BM_Parallel() local
423 ThreadPool pool(Env::Default(), "test", kNumThreads); in BM_ParallelFor() local
|
| /aosp_15_r20/external/perfetto/src/base/threading/ |
| H A D | util_unittest.cc | 66 std::thread thread([&main_to_background, &background_to_main] { in TEST() local
128 base::ThreadPool pool(1); in TEST() local
143 base::ThreadPool pool(1); in TEST() local
|
| /aosp_15_r20/external/tensorflow/tensorflow/core/profiler/backends/cpu/ |
| H A D | traceme_recorder_test.cc | 78 thread::ThreadPool pool(Env::Default(), "testpool", kNumThreads); in TEST() local
150 for (const auto& thread : results) { in TEST() local
181 auto& thread = id_and_thread.second; in TEST() local
|
| /aosp_15_r20/external/vulkan-validation-layers/layers/generated/ |
| H A D | thread_safety.h | 65 loader_platform_thread_id thread; member
473 VkCommandPool pool = bucket.command_pool_map[object]; in WRAPPER() local
484 VkCommandPool pool = bucket.command_pool_map[object]; variable
492 VkCommandPool pool = bucket.command_pool_map[object]; in StartReadObject() local
504 VkCommandPool pool = bucket.command_pool_map[object]; in FinishReadObject() local
|
| /aosp_15_r20/external/pytorch/torch/csrc/lazy/core/ |
| H A D | thread_pool.cpp | 38 for (auto& thread : threads_) { in ~ThreadPool() local
78 std::thread thread(std::move(closure)); in ScheduleOnThread() local
104 static ThreadPool* pool = in GetIoThreadPool() local
|