Home
last modified time | relevance | path

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

1234

/external/autotest/server/cros/tradefed_test_unittest_data/
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 …]
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 …]
/external/python/cpython3/Lib/concurrent/futures/
D__init__.py40 global ProcessPoolExecutor, ThreadPoolExecutor
48 from .thread import ThreadPoolExecutor as te
49 ThreadPoolExecutor = te
/external/swiftshader/third_party/llvm-7.0/llvm/lib/Support/
DParallel.cpp64 class ThreadPoolExecutor : public Executor { class
66 explicit ThreadPoolExecutor(unsigned ThreadCount = hardware_concurrency()) in ThreadPoolExecutor() function in __anon881c7aac0111::ThreadPoolExecutor
78 ~ThreadPoolExecutor() override { in ~ThreadPoolExecutor()
116 static ThreadPoolExecutor exec; in getDefaultExecutor()
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
DSynchronousHttpClient.java22 import java.util.concurrent.ThreadPoolExecutor;
27 ThreadPoolExecutor executor;
32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel, in prepare()
DOkHttpAsync.java28 import java.util.concurrent.ThreadPoolExecutor;
52 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel, in prepare()
/external/sl4a/Utils/src/com/googlecode/android_scripting/
DSingleThreadExecutor.java20 import java.util.concurrent.ThreadPoolExecutor;
23 public class SingleThreadExecutor extends ThreadPoolExecutor {
/external/python/futures/docs/
Dindex.rst11 :class:`ThreadPoolExecutor` or separate processes using
20 subclasses: :class:`ThreadPoolExecutor` and :class:`ProcessPoolExecutor`.
29 with ThreadPoolExecutor(max_workers=1) as executor:
66 with ThreadPoolExecutor(max_workers=4) as e:
73 ThreadPoolExecutor Objects
76 The :class:`ThreadPoolExecutor` class is an :class:`Executor` subclass that uses
96 executor = ThreadPoolExecutor(max_workers=2)
110 executor = ThreadPoolExecutor(max_workers=1)
113 .. class:: ThreadPoolExecutor(max_workers)
119 ThreadPoolExecutor Example
[all …]
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_server_test.py32 futures.ThreadPoolExecutor(max_workers=5),
41 server = grpc.server(futures.ThreadPoolExecutor(max_workers=5))
/external/python/futures/
Dprimes.py6 from concurrent.futures import ThreadPoolExecutor, ProcessPoolExecutor
35 with ThreadPoolExecutor(10) as executor:
Dcrawl.py13 from concurrent.futures import (as_completed, ThreadPoolExecutor,
66 ThreadPoolExecutor(10)))]:
/external/guava/guava/src/com/google/common/util/concurrent/
DMoreExecutors.java48 import java.util.concurrent.ThreadPoolExecutor;
49 import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
85 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
147 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
176 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
213 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
227 private static void useDaemonThreadFactory(ThreadPoolExecutor executor) { in useDaemonThreadFactory()
/external/python/cpython3/Doc/library/
Dconcurrent.futures.rst18 :class:`ThreadPoolExecutor`, or separate processes, using
37 with ThreadPoolExecutor(max_workers=1) as executor:
65 :class:`ThreadPoolExecutor`, *chunksize* has no effect.
91 with ThreadPoolExecutor(max_workers=4) as e:
98 ThreadPoolExecutor chapter
101 :class:`ThreadPoolExecutor` is an :class:`Executor` subclass that uses a pool of
119 executor = ThreadPoolExecutor(max_workers=2)
131 executor = ThreadPoolExecutor(max_workers=1)
135 .. class:: ThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=(…
149 multiplied by ``5``, assuming that :class:`ThreadPoolExecutor` is often
[all …]
/external/owasp/sanitizer/src/tests/org/owasp/html/
DHtmlSanitizerFuzzerTest.java33 import java.util.concurrent.ThreadPoolExecutor;
75 ThreadPoolExecutor executor = new ThreadPoolExecutor( in testFuzzHtmlParser()
/external/vogar/src/vogar/util/
DThreads.java22 import java.util.concurrent.ThreadPoolExecutor;
50 return new ThreadPoolExecutor(count, count, 10, TimeUnit.SECONDS, in fixedThreadsExecutor()
/external/setupcompat/main/java/com/google/android/setupcompat/internal/
DExecutorProvider.java24 import java.util.concurrent.ThreadPoolExecutor;
82 return new ThreadPoolExecutor( in createSizeBoundedExecutor()
/external/testng/src/main/java/org/testng/internal/thread/
DExecutorAdapter.java7 import java.util.concurrent.ThreadPoolExecutor;
15 public class ExecutorAdapter extends ThreadPoolExecutor implements IExecutor {
DThreadUtil.java12 import java.util.concurrent.ThreadPoolExecutor;
46 new ThreadPoolExecutor(threadPoolSize, threadPoolSize, in execute()
/external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/
DWebSocketCall.java35 import java.util.concurrent.ThreadPoolExecutor;
162 ThreadPoolExecutor replyExecutor = in create()
163 new ThreadPoolExecutor(1, 1, 1, SECONDS, new LinkedBlockingDeque<Runnable>(), in create()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DTrafficControlProxy.java32 import java.util.concurrent.ThreadPoolExecutor;
53 private final ThreadPoolExecutor executor =
54 new ThreadPoolExecutor(5, 10, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
DNettyFlowControlTest.java41 import java.util.concurrent.ThreadPoolExecutor;
73 private static final ThreadPoolExecutor executor =
74 new ThreadPoolExecutor(1, 10, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
DProxyTest.java29 import java.util.concurrent.ThreadPoolExecutor;
40 private static ThreadPoolExecutor executor =
41 new ThreadPoolExecutor(8, 8, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/
DFifoPriorityThreadPoolExecutor.java7 import java.util.concurrent.ThreadPoolExecutor;
17 public class FifoPriorityThreadPoolExecutor extends ThreadPoolExecutor {
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DMoreExecutorsTest.java73 import java.util.concurrent.ThreadPoolExecutor;
534 ThreadPoolExecutor executor = new ThreadPoolExecutor( in testGetExitingExcutorService_executorSetToUseDaemonThreads()
542 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExcutorService_executorDelegatesToOriginal()
551 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExcutorService_shutdownHookRegistered()
/external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/
DDispatcher.java27 import java.util.concurrent.ThreadPoolExecutor;
63 executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS, in getExecutorService()

1234