python线程池 示例

以下是一个简单的Python线程池示例：

import concurrent.futures

def worker(num):
    """线程池中的工作函数"""
    print(f"工作线程 {num} 开始执行")
    # 这里可以进行一些耗时的任务
    print(f"工作线程 {num} 执行完成")

if __name__ == "__main__":
    # 创建一个最大线程数为 3 的线程池
    with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
        # 提交 5 个工作任务
        for i in range(5):
            executor.submit(worker, i)

在这个示例中，我们使用了Python标准库concurrent.futures中的ThreadPoolExecutor类来创建一个最大线程数为3的线程池。然后，我们通过executor.submit()方法向线程池中提交了5个工作任务。每个工作任务都会调用worker()函数来执行一些耗时的任务。当线程池中的某个线程完成任务后，它会自动继续执行下一个任务，直到所有任务都完成为止。

相关问题

python 线程池示例

在Python中，`concurrent.futures`模块提供了一个线程池来并发执行任务。下面是一个简单的线程池示例：

import concurrent.futures

# 定义一个耗时任务，这里我们只是简单地模拟一个耗时操作
def long_running_task(n):
    import time
    time.sleep(n)
    return n * 2

# 创建一个线程池
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
    # 提交任务到线程池
    future_to_url = {executor.submit(long_running_task, n): n for n in range(10)}

    # 等待所有任务完成并打印结果
    for future in concurrent.futures.as_completed(future_to_url):
        url = future_to_url[future]
        try:
            data = future.result()
            print(f"Task {url} returned {data}")
        except Exception as exc:
            print(f"Exception raised for {url}: {exc}")

在这个例子中，我们创建了一个线程池，最大工作线程数设为5。然后提交了10个任务到线程池，每个任务都会运行`long_running_task`函数。`as_completed`函数会按顺序返回已完成的任务。

python 线程池

线程池是在多线程编程中常用的一种技术，它可以用来管理和复用线程，从而提高程序的性能和效率。

在Python中，可以使用内置的`concurrent.futures`模块来创建线程池。这个模块提供了`ThreadPoolExecutor`类，它可以用来创建和管理线程池。

下面是一个简单的示例代码，演示了如何使用线程池来执行一批任务：

import concurrent.futures

# 定义一个任务函数
def task(n):
    print(f"Executing task {n}")
    return n * n

# 创建一个线程池
with concurrent.futures.ThreadPoolExecutor() as executor:
    # 提交任务给线程池进行执行
    future1 = executor.submit(task, 1)
    future2 = executor.submit(task, 2)

    # 获取任务的返回结果
    result1 = future1.result()
    result2 = future2.result()

    print(f"Result 1: {result1}")
    print(f"Result 2: {result2}")

在这个例子中，我们首先定义了一个任务函数`task`，它接收一个参数，并返回参数的平方。然后，我们使用`ThreadPoolExecutor`创建了一个线程池，并使用`submit`方法提交了两个任务给线程池。每个任务都会在一个新的线程中执行。

通过`future.result()`方法可以获取每个任务的返回结果。最后，我们打印出了每个任务的结果。

注意，线程池会自动管理线程的创建和销毁，你只需要提交任务给线程池即可。线程池会根据系统资源和线程池的配置自动调整线程数量，以达到最佳的性能和效率。

希望这个示例对你理解Python线程池有所帮助！如果你还有其他问题，请随时提出。