/aosp_15_r20/libcore/jsr166-tests/src/test/java/jsr166/ |
H A D | ThreadPoolExecutorTest.java | 32 import java.util.concurrent.ThreadPoolExecutor; 50 static class ExtendedTPE extends ThreadPoolExecutor { 91 final ThreadPoolExecutor p = in testExecute() 92 new ThreadPoolExecutor(1, 1, in testExecute() 110 final ThreadPoolExecutor p = in testGetActiveCount() 111 new ThreadPoolExecutor(2, 2, in testGetActiveCount() 132 final ThreadPoolExecutor p = in testPrestartCoreThread() 133 new ThreadPoolExecutor(2, 6, in testPrestartCoreThread() 158 final ThreadPoolExecutor p = in testPrestartAllCoreThreads() 159 new ThreadPoolExecutor(2, 6, in testPrestartAllCoreThreads() [all …]
|
H A D | ThreadPoolExecutorSubclassTest.java | 32 import java.util.concurrent.ThreadPoolExecutor; 152 static class CustomTPE extends ThreadPoolExecutor { 238 final ThreadPoolExecutor p = in testExecute() 257 final ThreadPoolExecutor p = in testGetActiveCount() 279 final ThreadPoolExecutor p = in testPrestartCoreThread() 305 final ThreadPoolExecutor p = in testPrestartAllCoreThreads() 328 final ThreadPoolExecutor p = in testGetCompletedTaskCount() 361 final ThreadPoolExecutor p = in testGetCorePoolSize() 374 final ThreadPoolExecutor p = in testGetKeepAliveTime() 388 final ThreadPoolExecutor p = in testGetThreadFactory() [all …]
|
/aosp_15_r20/libcore/ojluni/src/test/java/util/concurrent/tck/ |
H A D | ThreadPoolExecutorTest.java | 66 import java.util.concurrent.ThreadPoolExecutor; 86 static class ExtendedTPE extends ThreadPoolExecutor { 128 final ThreadPoolExecutor p = in testExecute() 129 new ThreadPoolExecutor(1, 1, in testExecute() 148 final ThreadPoolExecutor p = in testGetActiveCount() 149 new ThreadPoolExecutor(2, 2, in testGetActiveCount() 171 final ThreadPoolExecutor p = in testPrestartCoreThread() 172 new ThreadPoolExecutor(2, 6, in testPrestartCoreThread() 198 final ThreadPoolExecutor p = in testPrestartAllCoreThreads() 199 new ThreadPoolExecutor(2, 6, in testPrestartAllCoreThreads() [all …]
|
H A D | ThreadPoolExecutorSubclassTest.java | 65 import java.util.concurrent.ThreadPoolExecutor; 187 static class CustomTPE extends ThreadPoolExecutor { 274 final ThreadPoolExecutor p = in testExecute() 294 final ThreadPoolExecutor p = in testGetActiveCount() 317 final ThreadPoolExecutor p = in testPrestartCoreThread() 344 final ThreadPoolExecutor p = in testPrestartAllCoreThreads() 368 final ThreadPoolExecutor p = in testGetCompletedTaskCount() 402 final ThreadPoolExecutor p = in testGetCorePoolSize() 416 final ThreadPoolExecutor p = in testGetKeepAliveTime() 431 final ThreadPoolExecutor p = in testGetThreadFactory() [all …]
|
/aosp_15_r20/packages/modules/HealthFitness/service/java/com/android/server/healthconnect/ |
D | HealthConnectThreadScheduler.java | 31 import java.util.concurrent.ThreadPoolExecutor; 58 static volatile ThreadPoolExecutor sBackgroundThreadExecutor = createBackgroundExecutor(); 62 static volatile ThreadPoolExecutor sInternalBackgroundExecutor = 67 static volatile ThreadPoolExecutor sForegroundExecutor = createForegroundExecutor(); 71 static volatile ThreadPoolExecutor sControllerExecutor = createControllerExecutor(); 82 private static ThreadPoolExecutor createInternalBackgroundExecutor() { in createInternalBackgroundExecutor() 83 return new ThreadPoolExecutor( in createInternalBackgroundExecutor() 92 private static ThreadPoolExecutor createBackgroundExecutor() { in createBackgroundExecutor() 93 return new ThreadPoolExecutor( in createBackgroundExecutor() 102 private static ThreadPoolExecutor createForegroundExecutor() { in createForegroundExecutor() [all …]
|
/aosp_15_r20/external/autotest/server/cros/tradefed/tradefed_utils_unittest_data/ |
H A D | GtsPlacementTestCases.txt | 54 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 55 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) 90 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 91 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) 116 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 117 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) 136 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 137 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) 162 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 163 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) [all …]
|
H A D | CtsAppTestCases-retry.txt | 53 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 54 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) 76 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 77 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) 112 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 113 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) 134 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 135 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) 172 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1133) 173 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:607) [all …]
|
/aosp_15_r20/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
H A D | ThreadPoolExecutor.java | 41 public class ThreadPoolExecutor extends java.util.concurrent.AbstractExecutorService { class 43 public ThreadPoolExecutor( in ThreadPoolExecutor() method in ThreadPoolExecutor 52 public ThreadPoolExecutor( in ThreadPoolExecutor() method in ThreadPoolExecutor 62 public ThreadPoolExecutor( in ThreadPoolExecutor() method in ThreadPoolExecutor 72 public ThreadPoolExecutor( in ThreadPoolExecutor() method in ThreadPoolExecutor 163 private void addWorkerFailed(java.util.concurrent.ThreadPoolExecutor.Worker w) { in addWorkerFailed() 168 java.util.concurrent.ThreadPoolExecutor.Worker w, boolean completedAbruptly) { in processWorkerExit() 176 final void runWorker(java.util.concurrent.ThreadPoolExecutor.Worker w) { in runWorker() 393 private final java.util.HashSet<java.util.concurrent.ThreadPoolExecutor.Worker> workers; 407 java.lang.Runnable r, java.util.concurrent.ThreadPoolExecutor e) { in rejectedExecution() [all …]
|
/aosp_15_r20/external/swiftshader/third_party/llvm-16.0/llvm/lib/Support/ |
H A D | Parallel.cpp | 49 class ThreadPoolExecutor : public Executor { class 51 explicit ThreadPoolExecutor(ThreadPoolStrategy S = hardware_concurrency()) { in ThreadPoolExecutor() function in llvm::parallel::detail::__anon7a9857a90111::ThreadPoolExecutor 80 ~ThreadPoolExecutor() override { in ~ThreadPoolExecutor() 91 static void *call() { return new ThreadPoolExecutor(strategy); } in call() 94 static void call(void *Ptr) { ((ThreadPoolExecutor *)Ptr)->stop(); } in call() 148 static ManagedStatic<ThreadPoolExecutor, ThreadPoolExecutor::Creator, in getDefaultExecutor() 149 ThreadPoolExecutor::Deleter> in getDefaultExecutor() 151 static std::unique_ptr<ThreadPoolExecutor> Exec(&(*ManagedExec)); in getDefaultExecutor()
|
/aosp_15_r20/external/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
H A D | Parallel.cpp | 40 class ThreadPoolExecutor : public Executor { class 42 explicit ThreadPoolExecutor(unsigned ThreadCount = hardware_concurrency()) { in ThreadPoolExecutor() function in llvm::parallel::detail::__anon1349bfa30111::ThreadPoolExecutor 70 ~ThreadPoolExecutor() override { in ~ThreadPoolExecutor() 81 static void call(void *Ptr) { ((ThreadPoolExecutor *)Ptr)->stop(); } in call() 132 static ManagedStatic<ThreadPoolExecutor, object_creator<ThreadPoolExecutor>, in getDefaultExecutor() 133 ThreadPoolExecutor::Deleter> in getDefaultExecutor() 135 static std::unique_ptr<ThreadPoolExecutor> Exec(&(*ManagedExec)); in getDefaultExecutor()
|
/aosp_15_r20/packages/modules/AppSearch/testing/appsindexertests/src/com/android/server/appsearch/appsindexer/ |
D | AppsIndexerUserInstanceTest.java | 66 import java.util.concurrent.ThreadPoolExecutor; 75 private ThreadPoolExecutor mSingleThreadedExecutor; 89 new ThreadPoolExecutor( in setUp() 119 new ThreadPoolExecutor( in testFirstRun_schedulesUpdate() 174 new ThreadPoolExecutor( in testFirstRun_updateAlreadyRan_doesNotUpdate() 237 new ThreadPoolExecutor( in testHandleMultipleNotifications_onlyOneUpdateCanBeScheduledAndRun() 456 new ThreadPoolExecutor( in testStart_initialRun_schedulesUpdateJob() 505 new ThreadPoolExecutor( in testStart_subsequentRunWithNoScheduledJob_schedulesUpdateJob() 575 new ThreadPoolExecutor( in testUpdate_triggered_afterCompatibleSchemaChange() 613 new ThreadPoolExecutor( in testUpdate_triggered_afterIncompatibleSchemaChange() [all …]
|
/aosp_15_r20/packages/modules/HealthFitness/tests/unittests/src/com/android/server/healthconnect/ |
D | HealthConnectThreadSchedulerTest.java | 38 import java.util.concurrent.ThreadPoolExecutor; 42 private ThreadPoolExecutor mInternalTaskScheduler; 43 private ThreadPoolExecutor mControllerTaskScheduler; 44 private ThreadPoolExecutor mForegroundTaskScheduler; 45 private ThreadPoolExecutor mBackgroundTaskScheduler;
|
/aosp_15_r20/frameworks/base/core/java/android/os/ |
H A D | AsyncTask.java | 34 import java.util.concurrent.ThreadPoolExecutor; 226 private static ThreadPoolExecutor sBackupExecutor; 231 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { 238 sBackupExecutor = new ThreadPoolExecutor( 260 ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
|
/aosp_15_r20/development/samples/training/threadsample/src/com/example/android/threadsample/ |
H A D | PhotoManager.java | 29 import java.util.concurrent.ThreadPoolExecutor; 101 private final ThreadPoolExecutor mDownloadThreadPool; 104 private final ThreadPoolExecutor mDecodeThreadPool; 147 mDownloadThreadPool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, in PhotoManager() 153 mDecodeThreadPool = new ThreadPoolExecutor(NUMBER_OF_CORES, NUMBER_OF_CORES, in PhotoManager()
|
/aosp_15_r20/external/python/cpython3/Doc/library/ |
D | concurrent.futures.rst | 18 :class:`ThreadPoolExecutor`, or separate processes, using 38 with ThreadPoolExecutor(max_workers=1) as executor: 66 :class:`ThreadPoolExecutor`, *chunksize* has no effect. 101 with ThreadPoolExecutor(max_workers=4) as e: 111 ThreadPoolExecutor chapter 114 :class:`ThreadPoolExecutor` is an :class:`Executor` subclass that uses a pool of 132 executor = ThreadPoolExecutor(max_workers=2) 144 executor = ThreadPoolExecutor(max_workers=1) 148 .. class:: ThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=(… 153 All threads enqueued to ``ThreadPoolExecutor`` will be joined before the [all …]
|
/aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/concurrent/ |
D | ThreadPoolExecutor.java | 333 public class ThreadPoolExecutor extends AbstractExecutorService { class 1204 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1239 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1275 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1312 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 2070 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2097 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2120 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2157 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
|
/aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/20/libcore/ojluni/src/main/java/java/util/concurrent/ |
D | ThreadPoolExecutor.java | 333 public class ThreadPoolExecutor extends AbstractExecutorService { class 1204 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1239 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1275 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1312 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 2070 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2097 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2120 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2157 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
|
/aosp_15_r20/libcore/ojluni/src/main/java/java/util/concurrent/ |
H A D | ThreadPoolExecutor.java | 333 public class ThreadPoolExecutor extends AbstractExecutorService { class 1204 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1239 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1275 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 1312 public ThreadPoolExecutor(int corePoolSize, in ThreadPoolExecutor() method in ThreadPoolExecutor 2070 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2097 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2120 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution() 2157 public void rejectedExecution(Runnable r, ThreadPoolExecutor e) { in rejectedExecution()
|
/aosp_15_r20/development/tools/logblame/ |
H A D | sample.txt | 891 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1162) 892 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:636) 975 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1162) 976 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:636) 1163 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1162) 1164 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:636) 1263 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1162) 1264 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:636) 2106 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1162) 2107 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:636) [all …]
|
/aosp_15_r20/external/grpc-grpc/examples/python/async_streaming/ |
H A D | client.py | 15 from concurrent.futures import ThreadPoolExecutor 29 executor: ThreadPoolExecutor, argument 107 executor: ThreadPoolExecutor, channel: grpc.Channel, phone_number: str argument 119 executor = ThreadPoolExecutor()
|
/aosp_15_r20/external/grpc-grpc/src/python/grpcio/grpc/ |
H A D | _server.py | 826 default_thread_pool: futures.ThreadPoolExecutor, argument 827 ) -> futures.ThreadPoolExecutor: 829 behavior.experimental_thread_pool, futures.ThreadPoolExecutor 840 default_thread_pool: futures.ThreadPoolExecutor, argument 864 default_thread_pool: futures.ThreadPoolExecutor, argument 888 default_thread_pool: futures.ThreadPoolExecutor, argument 912 default_thread_pool: futures.ThreadPoolExecutor, argument 986 thread_pool: futures.ThreadPoolExecutor, argument 1018 thread_pool: futures.ThreadPoolExecutor, argument 1079 thread_pool: futures.ThreadPoolExecutor [all …]
|
/aosp_15_r20/external/grpc-grpc-java/android-interop-testing/src/main/java/io/grpc/android/integrationtest/ |
H A D | UdsTcpEndpointConnector.java | 32 import java.util.concurrent.ThreadPoolExecutor; 44 private final ThreadPoolExecutor executor = 45 new ThreadPoolExecutor( 51 new ThreadPoolExecutor.DiscardOldestPolicy());
|
/aosp_15_r20/external/grpc-grpc/examples/python/xds/ |
H A D | server.py | 66 experimental_thread_pool=futures.ThreadPoolExecutor( 108 futures.ThreadPoolExecutor(max_workers=_THREAD_POOL_SIZE) 119 futures.ThreadPoolExecutor(max_workers=_THREAD_POOL_SIZE), 126 futures.ThreadPoolExecutor(max_workers=_THREAD_POOL_SIZE)
|
/aosp_15_r20/libcore/luni/src/test/java/libcore/java/util/concurrent/ |
H A D | ThreadPoolExecutorTest.java | 22 import java.util.concurrent.ThreadPoolExecutor; 29 ThreadPoolExecutor tp = new ThreadPoolExecutor( in testCorePoolSizeGreaterThanMax()
|
/aosp_15_r20/packages/modules/RemoteKeyProvisioning/app/src/com/android/rkpdapp/ |
D | ThreadPool.java | 21 import java.util.concurrent.ThreadPoolExecutor; 37 ThreadPoolExecutor executor = 38 new ThreadPoolExecutor(/*corePoolSize=*/ NUMBER_OF_THREADS,
|