Home
last modified time | relevance | path

Searched defs:result_queue (Results 1 – 25 of 87) sorted by relevance

1234

/dports/devel/py-numba/numba-0.51.2/numba/cuda/tests/cudapy/
H A Dtest_ipc.py20 def core_ipc_handle_test(the_work, result_queue): argument
34 def base_ipc_handle_test(handle, size, result_queue): argument
45 def serialize_ipc_handle_test(handle, result_queue): argument
59 def ipc_array_test(ipcarr, result_queue): argument
205 def staged_ipc_handle_test(handle, device_num, result_queue): argument
221 def staged_ipc_array_test(ipcarr, device_num, result_queue): argument
/dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/gslib/vendored/boto/boto/glacier/
H A Dconcurrent.py160 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
176 def _start_upload_threads(self, result_queue, upload_id, worker_queue, argument
188 def __init__(self, worker_queue, result_queue): argument
218 worker_queue, result_queue, num_retries=5, argument
313 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
352 def _start_download_threads(self, result_queue, worker_queue): argument
363 worker_queue, result_queue, argument
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/gsutil/gslib/vendored/boto/boto/glacier/
H A Dconcurrent.py160 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
176 def _start_upload_threads(self, result_queue, upload_id, worker_queue, argument
188 def __init__(self, worker_queue, result_queue): argument
218 worker_queue, result_queue, num_retries=5, argument
313 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
352 def _start_download_threads(self, result_queue, worker_queue): argument
363 worker_queue, result_queue, argument
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/depot_tools/external_bin/gsutil/gsutil_4.28/gsutil/third_party/boto/boto/glacier/
H A Dconcurrent.py160 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
176 def _start_upload_threads(self, result_queue, upload_id, worker_queue, argument
188 def __init__(self, worker_queue, result_queue): argument
218 worker_queue, result_queue, num_retries=5, argument
313 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
352 def _start_download_threads(self, result_queue, worker_queue): argument
363 worker_queue, result_queue, argument
/dports/devel/py-boto/boto-2.49.0/boto/glacier/
H A Dconcurrent.py160 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
176 def _start_upload_threads(self, result_queue, upload_id, worker_queue, argument
188 def __init__(self, worker_queue, result_queue): argument
218 worker_queue, result_queue, num_retries=5, argument
313 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
352 def _start_download_threads(self, result_queue, worker_queue): argument
363 worker_queue, result_queue, argument
/dports/deskutils/calibre/calibre-src-5.34.0/src/calibre/ebooks/metadata/sources/
H A Dgoogle.py242 result_queue, argument
322 result_queue, argument
352 result_queue, argument
H A Dedelweiss.py42 def __init__(self, basic_data, relevance, result_queue, br, timeout, log, plugin): argument
264 def identify(self, log, result_queue, abort, title=None, authors=None, # {{{ argument
341 def download_cover(self, log, result_queue, abort, # {{{ argument
H A Dopenlibrary.py23 def download_cover(self, log, result_queue, abort, argument
/dports/devel/py-tables/tables-3.6.1/examples/
H A Dmultiprocess_access_queues.py99 def __init__(self, read_queue, result_queue, write_queue, proc_num, argument
157 result_queue = result_queues[i] variable
/dports/net/google-cloud-sdk/google-cloud-sdk/platform/gsutil/gslib/vendored/boto/tests/unit/glacier/
H A Dtest_concurrent.py41 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
51 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/depot_tools/external_bin/gsutil/gsutil_4.28/gsutil/third_party/boto/tests/unit/glacier/
H A Dtest_concurrent.py41 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
51 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/third_party/gsutil/gslib/vendored/boto/tests/unit/glacier/
H A Dtest_concurrent.py41 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
51 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
/dports/devel/py-boto/boto-2.49.0/tests/unit/glacier/
H A Dtest_concurrent.py41 def _wait_for_upload_threads(self, hash_chunks, result_queue, total_parts): argument
51 def _wait_for_download_threads(self, filename, result_queue, total_parts): argument
/dports/editors/xi-core/xi-editor-0.3.0/rust/lsp-lib/src/
H A Dlib.rs40 mod result_queue; module
/dports/multimedia/vmaf/vmaf-2.3.0/third_party/libsvm/tools/
H A Dgrid.py245 def __init__(self,name,job_queue,result_queue,options): argument
298 def __init__(self,name,job_queue,result_queue,host,options): argument
311 def __init__(self,name,job_queue,result_queue,host,username,password,options): argument
/dports/science/libsvm/libsvm-3.23/tools/
H A Dgrid.py245 def __init__(self,name,job_queue,result_queue,options): argument
298 def __init__(self,name,job_queue,result_queue,host,options): argument
311 def __init__(self,name,job_queue,result_queue,host,username,password,options): argument
/dports/science/libsvm-python/libsvm-3.23/tools/
H A Dgrid.py245 def __init__(self,name,job_queue,result_queue,options): argument
298 def __init__(self,name,job_queue,result_queue,host,options): argument
311 def __init__(self,name,job_queue,result_queue,host,username,password,options): argument
/dports/biology/viennarna/ViennaRNA-2.4.18/src/libsvm-3.24/tools/
H A Dgrid.py245 def __init__(self,name,job_queue,result_queue,options): argument
298 def __init__(self,name,job_queue,result_queue,host,options): argument
311 def __init__(self,name,job_queue,result_queue,host,username,password,options): argument
/dports/devel/py-pylama/pylama-7.7.1/pylama/
H A Dcheck_async.py29 def __init__(self, path_queue, result_queue): argument
/dports/net/google-cloud-sdk/google-cloud-sdk/lib/third_party/concurrent/python2/concurrent/futures/
H A Dprocess.py108 def _process_worker(call_queue, result_queue): argument
179 result_queue): argument
/dports/devel/mercurial/mercurial-6.0/mercurial/thirdparty/concurrent/futures/
H A Dprocess.py110 def _process_worker(call_queue, result_queue): argument
181 result_queue): argument
/dports/lang/spidermonkey60/firefox-60.9.0/third_party/python/futures/concurrent/futures/
H A Dprocess.py108 def _process_worker(call_queue, result_queue): argument
179 result_queue): argument
/dports/www/firefox-legacy/firefox-52.8.0esr/python/futures/concurrent/futures/
H A Dprocess.py108 def _process_worker(call_queue, result_queue): argument
179 result_queue): argument
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/futures/concurrent/futures/
H A Dprocess.py108 def _process_worker(call_queue, result_queue): argument
179 result_queue): argument
/dports/databases/py-gdbm/Python-3.8.12/Lib/concurrent/futures/
H A Dprocess.py201 def _sendback_result(result_queue, work_id, result=None, exception=None): argument
211 def _process_worker(call_queue, result_queue, initializer, initargs): argument
295 result_queue, argument

1234