Home
last modified time | relevance | path

Searched refs:ProcessPoolExecutor (Results 1 - 7 of 7) sorted by relevance

/third_party/python/Lib/concurrent/futures/
H A D__init__.py31 'ProcessPoolExecutor',
41 global ProcessPoolExecutor, ThreadPoolExecutor
43 if name == 'ProcessPoolExecutor':
44 from .process import ProcessPoolExecutor as pe
45 ProcessPoolExecutor = pe
H A Dprocess.py4 """Implements ProcessPoolExecutor.
92 # call not protected by ProcessPoolExecutor._shutdown_lock
280 executor: A reference to the ProcessPoolExecutor that owns
294 # A weakref.ref to the ProcessPoolExecutor that owns this thread. Used
295 # to determine if the ProcessPoolExecutor has been garbage collected
610 Raised when a process in a ProcessPoolExecutor terminated abruptly
615 class ProcessPoolExecutor(_base.Executor): class
618 """Initializes a new ProcessPoolExecutor instance.
/third_party/python/Lib/
H A Dcompileall.py76 ProcessPoolExecutor = None
87 # Check if this is a system where ProcessPoolExecutor can function.
94 from concurrent.futures import ProcessPoolExecutor namespace
99 if workers != 1 and ProcessPoolExecutor is not None:
100 # If workers == 0, let ProcessPoolExecutor choose
102 with ProcessPoolExecutor(max_workers=workers) as executor:
/third_party/python/Lib/test/
H A Dtest_concurrent_futures.py155 executor_type = futures.ProcessPoolExecutor
162 self.skipTest("ProcessPoolExecutor unavailable on this system")
169 executor_type = futures.ProcessPoolExecutor
176 self.skipTest("ProcessPoolExecutor unavailable on this system")
181 executor_type = futures.ProcessPoolExecutor
188 self.skipTest("ProcessPoolExecutor unavailable on this system")
383 if self.executor_type == futures.ProcessPoolExecutor:
547 with futures.ProcessPoolExecutor(
557 executor = futures.ProcessPoolExecutor(
581 executor = futures.ProcessPoolExecutor(
[all...]
H A Dtest_compileall.py19 # compileall relies on ProcessPoolExecutor if ProcessPoolExecutor exists
21 from concurrent.futures import ProcessPoolExecutor namespace
251 @mock.patch('concurrent.futures.ProcessPoolExecutor')
262 @mock.patch('concurrent.futures.ProcessPoolExecutor')
268 @mock.patch('concurrent.futures.ProcessPoolExecutor')
276 @mock.patch('concurrent.futures.ProcessPoolExecutor', new=None)
/third_party/python/
H A Dsetup.py1590 ProcessPoolExecutor = None variable in main.DummyProcess
/third_party/python/Lib/test/test_asyncio/
H A Dtest_events.py2726 # ProcessPoolExecutor is not functional when the
2731 pool = concurrent.futures.ProcessPoolExecutor()

Completed in 14 milliseconds