CentOS中Python多线程如何实现

发布时间:2025-05-01 02:56:25

阅读量:90

在CentOS系统中，使用Python实现多线程可以通过多种方式。以下是一些常见的方法：

1. 使用`threading`模块

Python标准库中的threading模块提供了创建和管理线程的工具。

import threading

def worker():
    """线程要执行的函数"""
    print(f"Thread {threading.current_thread().name} is running")

# 创建线程
threads = []
for i in range(5):
    thread = threading.Thread(target=worker, name=f"Thread-{i}")
    threads.append(thread)
    thread.start()

# 等待所有线程完成
for thread in threads:
    thread.join()

print("All threads have finished.")

2. 使用`concurrent.futures`模块

concurrent.futures模块提供了一个高级接口来执行异步任务，支持线程池和进程池。

from concurrent.futures import ThreadPoolExecutor

def worker(num):
    """线程要执行的函数"""
    print(f"Thread {num} is running")
    return num * num

# 创建线程池
with ThreadPoolExecutor(max_workers=5) as executor:
    # 提交任务
    futures = [executor.submit(worker, i) for i in range(5)]
    
    # 获取结果
    for future in concurrent.futures.as_completed(futures):
        print(f"Result: {future.result()}")

print("All threads have finished.")

3. 使用`multiprocessing`模块

虽然multiprocessing模块主要用于创建进程，但它也可以用于实现多线程。不过，对于CPU密集型任务，使用多进程通常更有效。

import multiprocessing

def worker(num):
    """线程要执行的函数"""
    print(f"Process {num} is running")
    return num * num

if __name__ == "__main__":
    # 创建进程池
    with multiprocessing.Pool(processes=5) as pool:
        # 提交任务
        results = pool.map(worker, range(5))
    
    print(results)
    print("All processes have finished.")