Home
last modified time | relevance | path

Searched refs:ThreadPoolExecutor (Results 1 – 25 of 1037) sorted by relevance

12345678910>>...42

/aosp_15_r20/libcore/jsr166-tests/src/test/java/jsr166/
H A DThreadPoolExecutorTest.java32 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 DThreadPoolExecutorSubclassTest.java32 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 DThreadPoolExecutorTest.java66 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 DThreadPoolExecutorSubclassTest.java65 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/
DHealthConnectThreadScheduler.java31 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 DGtsPlacementTestCases.txt54 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 DCtsAppTestCases-retry.txt53 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 DThreadPoolExecutor.java41 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 DParallel.cpp49 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 DParallel.cpp40 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/
DAppsIndexerUserInstanceTest.java66 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/
DHealthConnectThreadSchedulerTest.java38 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 DAsyncTask.java34 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 DPhotoManager.java29 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/
Dconcurrent.futures.rst18 :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/
DThreadPoolExecutor.java333 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/
DThreadPoolExecutor.java333 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 DThreadPoolExecutor.java333 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 Dsample.txt891 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 Dclient.py15 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.py826 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 DUdsTcpEndpointConnector.java32 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 Dserver.py66 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 DThreadPoolExecutorTest.java22 import java.util.concurrent.ThreadPoolExecutor;
29 ThreadPoolExecutor tp = new ThreadPoolExecutor( in testCorePoolSizeGreaterThanMax()
/aosp_15_r20/packages/modules/RemoteKeyProvisioning/app/src/com/android/rkpdapp/
DThreadPool.java21 import java.util.concurrent.ThreadPoolExecutor;
37 ThreadPoolExecutor executor =
38 new ThreadPoolExecutor(/*corePoolSize=*/ NUMBER_OF_THREADS,

12345678910>>...42