### 修改 `for` 循环中的 `getquery` 函数调用为多线程执行 为了将 `for` 循环内的 `getquery` 调用更改为多线程方式，在 Python 中可以利用 `threading.Thread` 类来创建多个线程并行处理这些函数调用。下面展示了一种可能的方法，其中还包括了如何收集各个线程的结果。 ```python from threading import Thread, Lock import queue def getquery(param): # 假设这是要并发运行的任务 result = f"Processed {param}" return result params_list = ['item1', 'item2', 'item3'] # 参数列表 result_queue = queue.Queue() lock = Lock() def threaded_getquery(q, param): ret_val = getquery(param) with lock: q.put(ret_val) threads = [] for item in params_list: thread = Thread(target=threaded_getquery, args=(result_queue, item)) threads.append(thread) thread.start() for t in threads: t.join() results = [] while not result_queue.empty(): results.append(result_queue.get()) print(results) ``` 上述代码展示了如何使用队列和锁机制确保线程安全地存储结果[^2]。每个线程都将自己的计算结果放入共享的 `queue.Queue()` 实例中，并且通过 `Lock` 来防止竞争条件的发生。 #### 使用 `concurrent.futures` 进一步简化操作 如果希望进一步简化这一过程，则可以采用更高层次抽象库——`concurrent.futures` 的 `ThreadPoolExecutor`. 它允许更加简洁地管理线程池以及获取它们完成后的结果： ```python from concurrent.futures import ThreadPoolExecutor, as_completed with ThreadPoolExecutor(max_workers=len(params_list)) as executor: future_to_param = {executor.submit(getquery, p): p for p in params_list} for future in as_completed(future_to_param): try: data = future.result() print(data) except Exception as exc: print('%r generated an exception: %s' % (future_to_param[future], exc)) ``` 这种方法不仅减少了手动管理线程的工作量，还提供了更好的异常处理能力[^4].