| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
| D | Parallel.cpp | 40 class ThreadPoolExecutor : public Executor { class
42 explicit ThreadPoolExecutor(unsigned ThreadCount = hardware_concurrency()) { in ThreadPoolExecutor() function in llvm::parallel::detail::__anon2b5c2c130111::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()
|
| /third_party/python/Lib/concurrent/futures/ |
| D | __init__.py | 41 global ProcessPoolExecutor, ThreadPoolExecutor
49 from .thread import ThreadPoolExecutor as te
50 ThreadPoolExecutor = te
|
| D | thread.py | 118 class ThreadPoolExecutor(_base.Executor): class
|
| /third_party/python/Lib/test/test_importlib/partial/ |
| D | cfimport.py | 13 from concurrent.futures import ThreadPoolExecutor
20 from concurrent.futures.thread import ThreadPoolExecutor
|
| /third_party/ejdb/src/bindings/ejdb2_react_native/binding/android/src/main/java/com/softmotions/ejdb2/ |
| D | EJDB2Package.java | 9 import java.util.concurrent.ThreadPoolExecutor;
20 private static final Executor executor = new ThreadPoolExecutor(0, 5, 60L, TimeUnit.SECONDS,
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 18 :class:`ThreadPoolExecutor`, or separate processes, using
37 with ThreadPoolExecutor(max_workers=1) as executor:
65 :class:`ThreadPoolExecutor`, *chunksize* has no effect.
100 with ThreadPoolExecutor(max_workers=4) as e:
110 ThreadPoolExecutor chapter
113 :class:`ThreadPoolExecutor` is an :class:`Executor` subclass that uses a pool of
131 executor = ThreadPoolExecutor(max_workers=2)
143 executor = ThreadPoolExecutor(max_workers=1)
147 .. class:: ThreadPoolExecutor(max_workers=None, thread_name_prefix='', initializer=None, initargs=(…
161 multiplied by ``5``, assuming that :class:`ThreadPoolExecutor` is often
[all …]
|
| D | asyncio-eventloop.rst | 184 the threads in the :class:`ThreadPoolExecutor`. After calling this method, a
1116 with concurrent.futures.ThreadPoolExecutor() as pool:
1138 (:class:`~concurrent.futures.ThreadPoolExecutor`) to set the
1145 :class:`~concurrent.futures.ThreadPoolExecutor`.
1149 :class:`~concurrent.futures.ThreadPoolExecutor` is deprecated and
1153 :class:`concurrent.futures.ThreadPoolExecutor`.
|
| D | asyncio-dev.rst | 106 :class:`concurrent.futures.ThreadPoolExecutor` to execute
|
| /third_party/mesa3d/.gitlab-ci/bin/ |
| D | ci_run_n_monitor.py | 17 from concurrent.futures import ThreadPoolExecutor
214 with ThreadPoolExecutor(max_workers=6) as exe:
|
| /third_party/flatbuffers/grpc/examples/python/greeter/ |
| D | server.py | 48 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
|
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 154 executor_type = futures.ThreadPoolExecutor
424 with futures.ThreadPoolExecutor(max_workers=5) as e:
433 executor = futures.ThreadPoolExecutor(max_workers=5)
448 executor = futures.ThreadPoolExecutor(max_workers=5)
461 executor = futures.ThreadPoolExecutor(
473 executor = futures.ThreadPoolExecutor(max_workers=5)
929 with futures.ThreadPoolExecutor(1) as pool:
|
| D | test_inspect.py | 23 from concurrent.futures import ThreadPoolExecutor
25 ThreadPoolExecutor = None variable
4312 @unittest.skipIf(ThreadPoolExecutor is None,
4320 inspect.getsource(ThreadPoolExecutor).splitlines())
|
| D | test_context.py | 354 tp = concurrent.futures.ThreadPoolExecutor(max_workers=10)
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_futures.py | 478 ex = concurrent.futures.ThreadPoolExecutor(1)
495 ex = concurrent.futures.ThreadPoolExecutor(1)
506 ex = concurrent.futures.ThreadPoolExecutor(1)
520 ex = concurrent.futures.ThreadPoolExecutor(1)
|
| /third_party/python/Lib/distutils/command/ |
| D | build_ext.py | 456 from concurrent.futures import ThreadPoolExecutor
464 with ThreadPoolExecutor(max_workers=workers) as executor:
|
| /third_party/flatbuffers/grpc/tests/ |
| D | grpctest.py | 104 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
|
| /third_party/ejdb/src/bindings/ejdb2_flutter/android/src/main/java/com/softmotions/ejdb2/ |
| D | Ejdb2FlutterPlugin.java | 9 import java.util.concurrent.ThreadPoolExecutor;
40 static final Executor executor = new ThreadPoolExecutor(0, 5, 60L, TimeUnit.SECONDS,
|
| /third_party/python/Misc/NEWS.d/ |
| D | 3.6.3rc1.rst | 376 Fix concurrent.futures.thread.ThreadPoolExecutor threads to have a non
378 They will now identify themselves as "ThreadPoolExecutor-y_n".
427 concurrent.futures: WorkItem.run() used by ThreadPoolExecutor now breaks a
|
| D | 3.7.0b1.rst | 384 ``concurrent.futures`` imports ``ThreadPoolExecutor`` and
386 asyncio`` about 15% faster because asyncio uses only ``ThreadPoolExecutor``
|
| D | 3.6.0a4.rst | 221 Add to concurrent.futures.thread.ThreadPoolExecutor() the ability to specify
|
| D | 3.8.0b1.rst | 570 Change default *max_workers* of ``ThreadPoolExecutor`` from ``cpu_count() *
1499 Change ThreadPoolExecutor to use existing idle threads before spinning up
|
| /third_party/python/Lib/asyncio/ |
| D | base_events.py | 808 executor = concurrent.futures.ThreadPoolExecutor(
816 if not isinstance(executor, concurrent.futures.ThreadPoolExecutor):
|
| /third_party/python/Doc/whatsnew/ |
| D | 3.9.rst | 357 :class:`~concurrent.futures.ThreadPoolExecutor` to finish closing. Also,
398 Removed daemon threads from :class:`~concurrent.futures.ThreadPoolExecutor`
|
| D | 3.7.rst | 817 :class:`ThreadPoolExecutor <concurrent.futures.ThreadPoolExecutor>` now
2431 * The ``submit()`` method of :class:`concurrent.futures.ThreadPoolExecutor`
|
| /third_party/python/Doc/faq/ |
| D | library.rst | 296 especially the :mod:`~concurrent.futures.ThreadPoolExecutor` class.
|