concurrent.futures 执行器与 Future。
固定源码版本：2f2318653f6f794dddd321eff7c9d4b7b174643f。本表共 36 条静态出现记录；不是运行次数。
同一个直接 API 表达式只记为 api_call 或 api_reference 中的一类。实例候选不计入直接原生 API 总数。
| ID | 位置 / 快照 | 所属符号 | 种类 | API / 语法 | 来源判定 | 源码行 |
|---|---|---|---|---|---|---|
| occ-000643 | slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:10 · 快照 | <module> | import | concurrent.futures.ThreadPoolExecutor | explicit_import | from concurrent.futures import ThreadPoolExecutor |
| occ-000651 | slime/backends/megatron_utils/update_weight/update_weight_from_disk_delta.py:273 · 快照 | UpdateWeightFromDiskDelta._encode_delta | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | pool = ThreadPoolExecutor(max_workers=NUM_WORKERS) |
| occ-000749 | slime/data/queue_data_source.py:19 · 快照 | <module> | import | concurrent.futures.ThreadPoolExecutor | explicit_import | from concurrent.futures import ThreadPoolExecutor |
| occ-000800 | slime/data/queue_data_source.py:1035 · 快照 | QueueReader.init | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | self._reader = ThreadPoolExecutor(max_workers=1, thread_name_prefix=“queue-input”) |
| occ-001297 | slime/utils/routed_experts.py:5 · 快照 | <module> | import | concurrent.futures.Future | explicit_import | from concurrent.futures import Future, ThreadPoolExecutor |
| occ-001298 | slime/utils/routed_experts.py:5 · 快照 | <module> | import | concurrent.futures.ThreadPoolExecutor | explicit_import | from concurrent.futures import Future, ThreadPoolExecutor |
| occ-001299 | slime/utils/routed_experts.py:149 · 快照 | RoutedExpertsMicrobatchPrefetcher.init | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | ThreadPoolExecutor( |
| occ-001301 | slime/utils/routed_experts.py:181 · 快照 | RoutedExpertsMicrobatchPrefetcher | api_reference | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | def executor(self) -> ThreadPoolExecutor | None: |
| occ-001304 | slime/utils/routed_experts.py:211 · 快照 | RoutedExpertsMicrobatch.init | api_reference | concurrent.futures.Future | lexical_import_resolution | self._future: Future | None = None |
| occ-001405 | tests/pipeline_rl_test_helpers.py:8 · 快照 | <module> | import | concurrent.futures.ThreadPoolExecutor | explicit_import | from concurrent.futures import ThreadPoolExecutor |
| occ-001422 | tests/pipeline_rl_test_helpers.py:159 · 快照 | before_train_step | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(max_workers=len(_probes)) as pool: |
| occ-001424 | tests/pipeline_rl_test_helpers.py:164 · 快照 | before_train_step | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(max_workers=len(_probes)) as pool: |
| occ-001634 | tests/test_distributed_rollout.py:12 · 快照 | <module> | import | concurrent.futures.FIRST_COMPLETED | explicit_import | from concurrent.futures import FIRST_COMPLETED, Future, ThreadPoolExecutor, wait |
| occ-001635 | tests/test_distributed_rollout.py:12 · 快照 | <module> | import | concurrent.futures.Future | explicit_import | from concurrent.futures import FIRST_COMPLETED, Future, ThreadPoolExecutor, wait |
| occ-001636 | tests/test_distributed_rollout.py:12 · 快照 | <module> | import | concurrent.futures.ThreadPoolExecutor | explicit_import | from concurrent.futures import FIRST_COMPLETED, Future, ThreadPoolExecutor, wait |
| occ-001637 | tests/test_distributed_rollout.py:12 · 快照 | <module> | import | concurrent.futures.wait | explicit_import | from concurrent.futures import FIRST_COMPLETED, Future, ThreadPoolExecutor, wait |
| occ-001671 | tests/test_distributed_rollout.py:650 · 快照 | scheduler_factory.ray_wait | api_call | concurrent.futures.wait | lexical_import_resolution | done, pending = wait(refs, timeout=timeout, return_when=FIRST_COMPLETED) |
| occ-001672 | tests/test_distributed_rollout.py:650 · 快照 | scheduler_factory.ray_wait | api_reference | concurrent.futures.FIRST_COMPLETED | lexical_import_resolution | done, pending = wait(refs, timeout=timeout, return_when=FIRST_COMPLETED) |
| occ-001691 | tests/test_distributed_rollout.py:793 · 快照 | test_async_scheduler_fast_worker_fills_batch_without_waiting_for_slow_worker | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(1) as consumer: |
| occ-001696 | tests/test_distributed_rollout.py:810 · 快照 | test_slow_worker_control_does_not_block_collection_or_close | api_call | concurrent.futures.Future | lexical_import_resolution | stalled = Future() |
| occ-001699 | tests/test_distributed_rollout.py:821 · 快照 | test_slow_worker_control_does_not_block_collection_or_close | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(2) as callers: |
| occ-001710 | tests/test_distributed_rollout.py:884 · 快照 | test_scheduler_close_unblocks_waiting_consumer | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(1) as consumer: |
| occ-001759 | tests/test_distributed_rollout.py:1471 · 快照 | test_two_ray_nodes_generate_transfer_and_restore | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(1) as consumer: |
| occ-001794 | tests/test_distributed_rollout.py:2049 · 快照 | test_admission_pause_acknowledges_workers_without_waiting_for_responses | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(1) as pool: |
| occ-002250 | tools/convert_hf_to_fp8.py:23 · 快照 | <module> | import | concurrent.futures.ThreadPoolExecutor | explicit_import | from concurrent.futures import ThreadPoolExecutor |
| occ-002252 | tools/convert_hf_to_fp8.py:178 · 快照 | convert_fp8 | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(max_workers=max_workers) as executor: |
| occ-002256 | tools/convert_hf_to_int4_direct.py:17 · 快照 | <module> | import | concurrent.futures.ThreadPoolExecutor | explicit_import | from concurrent.futures import ThreadPoolExecutor |
| occ-002258 | tools/convert_hf_to_int4_direct.py:224 · 快照 | convert_int4 | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(max_workers=max_workers) as executor: |
| occ-002263 | tools/convert_torch_dist_to_hf_parallel.py:10 · 快照 | <module> | import | concurrent.futures.ThreadPoolExecutor | explicit_import | from concurrent.futures import ThreadPoolExecutor, as_completed |
| occ-002264 | tools/convert_torch_dist_to_hf_parallel.py:10 · 快照 | <module> | import | concurrent.futures.as_completed | explicit_import | from concurrent.futures import ThreadPoolExecutor, as_completed |
| occ-002268 | tools/convert_torch_dist_to_hf_parallel.py:147 · 快照 | WrappedStorageReader._parallel_preload_files | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(max_workers=self.max_workers) as executor: |
| occ-002270 | tools/convert_torch_dist_to_hf_parallel.py:154 · 快照 | WrappedStorageReader._parallel_preload_files | api_call | concurrent.futures.as_completed | lexical_import_resolution | for future in tqdm(as_completed(futures), total=len(futures), desc=“Pre-loading files”): |
| occ-002273 | tools/convert_torch_dist_to_hf_parallel.py:296 · 快照 | save_tensors | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(max_workers=max_workers) as executor: |
| occ-002275 | tools/convert_torch_dist_to_hf_parallel.py:298 · 快照 | save_tensors | api_call | concurrent.futures.as_completed | lexical_import_resolution | for future in tqdm(as_completed(futures), total=len(futures), desc=“Converting parameters”): |
| occ-002277 | tools/convert_torch_dist_to_hf_parallel.py:336 · 快照 | save_tensors | api_call | concurrent.futures.ThreadPoolExecutor | lexical_import_resolution | with ThreadPoolExecutor(max_workers=min(max_workers, num_files)) as executor: |
| occ-002279 | tools/convert_torch_dist_to_hf_parallel.py:338 · 快照 | save_tensors | api_call | concurrent.futures.as_completed | lexical_import_resolution | for future in tqdm(as_completed(futures), total=len(futures), desc=“Saving files”): |