| /third_party/python/Lib/test/ |
| H A D | _test_venv_multiprocessing.py | 1 import multiprocessing namespace
17 queue = multiprocessing.Queue()
18 fill_pool = multiprocessing.Process(
22 drain_pool = multiprocessing.Process(
33 test_pool = multiprocessing.Process(target=test_func)
|
| H A D | mp_fork_bomb.py | 1 import multiprocessing, sys namespace
11 multiprocessing.set_start_method(sys.argv[1])
13 multiprocessing.set_start_method('spawn')
15 p = multiprocessing.Process(target=foo)
|
| H A D | _test_multiprocessing.py | 2 # Unit tests for the multiprocessing package
45 import multiprocessing.connection namespace
46 import multiprocessing.dummy namespace
47 import multiprocessing.heap namespace
48 import multiprocessing.managers namespace
49 import multiprocessing.pool namespace
50 import multiprocessing.queues namespace
52 from multiprocessing import util
55 from multiprocessing import reduction
61 from multiprocessing
[all...] |
| H A D | mp_preload.py | 1 import multiprocessing namespace
3 multiprocessing.Lock()
11 ctx = multiprocessing.get_context("forkserver")
|
| /third_party/python/Doc/includes/ |
| H A D | mp_pool.py | 1 import multiprocessing namespace
13 multiprocessing.current_process().name,
45 with multiprocessing.Pool(PROCESSES) as pool:
132 except multiprocessing.TimeoutError:
145 except multiprocessing.TimeoutError:
152 multiprocessing.freeze_support()
|
| H A D | mp_newtype.py | 1 from multiprocessing import freeze_support
2 from multiprocessing.managers import BaseManager, BaseProxy
|
| /third_party/vixl/tools/ |
| H A D | threaded_tests.py | 28 import multiprocessing namespace
38 # Shared state for multiprocessing. Ideally the context should be passed with
39 # arguments, but constraints from the multiprocessing module prevent us from
40 # doing so: the shared variables (multiprocessing.Value) must be either global
42 n_tests_passed = multiprocessing.Value('i', 0)
43 n_tests_failed = multiprocessing.Value('i', 0)
44 n_tests_skipped = multiprocessing.Value('i', 0)
68 with multiprocessing.Manager() as manager:
|
| H A D | thread_pool.py | 29 import multiprocessing namespace
40 # multiprocessing module.
41 __run_tests_lock__ = multiprocessing.Lock()
49 pool = multiprocessing.Pool(num_threads)
|
| H A D | printer.py | 32 import multiprocessing namespace
51 __print_lock__ = multiprocessing.Lock()
52 __last_overwritable_line_length__ = multiprocessing.Value('i', 0)
53 __last_line_type__ = multiprocessing.Value('i', LINE_TYPE_NONE)
|
| H A D | clang_tidy.py | 29 import multiprocessing namespace
50 default=multiprocessing.cpu_count(),
51 const=multiprocessing.cpu_count(),
|
| H A D | generate_tests.py | 613 import multiprocessing namespace
692 default=multiprocessing.cpu_count(),
791 with multiprocessing.Pool(processes=args.jobs) as pool:
|
| H A D | lint.py | 32 import multiprocessing namespace
62 default=multiprocessing.cpu_count(),
63 const=multiprocessing.cpu_count(),
105 # The multiprocessing map_async function does not allow passing multiple
158 pool = multiprocessing.Pool(jobs)
|
| H A D | clang_format.py | 30 import multiprocessing namespace
65 default = multiprocessing.cpu_count(),
66 const = multiprocessing.cpu_count(),
|
| /third_party/skia/gn/toolchain/ |
| H A D | num_cpus.py | 10 import multiprocessing namespace
12 print(multiprocessing.cpu_count())
|
| /third_party/python/Lib/test/test_importlib/partial/ |
| H A D | pool_in_threads.py | 1 import multiprocessing namespace
9 with multiprocessing.Pool(1):
|
| /third_party/skia/tools/skqp/ |
| H A D | download_model.py | 8 import multiprocessing namespace
61 pool = multiprocessing.Pool(processes=multiprocessing.cpu_count() * 2)
|
| H A D | cut_release.py | 7 import multiprocessing namespace
45 pool = multiprocessing.Pool(processes=20)
120 pool = multiprocessing.Pool(processes=20)
|
| /third_party/rust/crates/minimal-lexical/etc/correctness/test-parse-random/ |
| H A D | runtests.py | 76 with ``multiprocessing``. Each test is launched as a subprocess.
99 import multiprocessing namespace
168 done = multiprocessing.Value(ctypes.c_bool)
169 queue = multiprocessing.Queue(maxsize=5)#(maxsize=1024)
172 worker = multiprocessing.Process(name='Worker-' + str(n + 1),
228 MAILBOX = multiprocessing.Queue()
|
| /third_party/mesa3d/ohos/ |
| H A D | build_mesa3d.py | 28 import multiprocessing namespace
35 nproc = multiprocessing.cpu_count()
|
| /third_party/vk-gl-cts/scripts/ |
| H A D | launchcontrol_build.py | 27 import multiprocessing namespace
59 threadCount = multiprocessing.cpu_count() + 1
|
| /third_party/skia/tools/ |
| H A D | check-headers-self-sufficient | 8 import multiprocessing namespace
81 # ...Except use a multiprocessing pool.
86 pool = multiprocessing.Pool()
|
| /third_party/node/deps/v8/tools/ |
| H A D | bigint-tester.py | 11 import multiprocessing namespace
343 pool = multiprocessing.Pool(multiprocessing.cpu_count())
|
| /third_party/node/deps/v8/tools/chrome/ |
| H A D | linux_perf.py | 17 import multiprocessing namespace
187 with multiprocessing.Pool() as pool:
|
| /third_party/node/deps/v8/tools/clusterfuzz/js_fuzzer/tools/ |
| H A D | minimize.py | 16 from multiprocessing import cpu_count
|
| /third_party/skia/tools/calmbench/ |
| H A D | calmbench.py | 13 import multiprocessing namespace
51 default_threads = max(1, multiprocessing.cpu_count() / 2);
|