博客

python多线程执行函数实现方法

  • Post category:Python

Python多线程执行函数可以通过两种方式实现，分别是使用threading模块和使用concurrent.futures模块。

  1. 使用threading模块

threading模块是Python标准库中用于多线程编程的模块，可以使用它来创建线程并执行相应的函数。下面是使用threading模块实现多线程执行函数的代码示例：

import threading

def func():
    print("Hello from thread", threading.current_thread().name)

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

# 启动线程
for t in threads:
    t.start()

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

在上面的代码中，我们定义了一个名为func的函数，该函数将作为线程的执行函数。使用循环创建了5个线程，并将它们添加到一个列表中。然后，我们循环启动每个线程，并等待它们全部执行完毕。

  1. 使用concurrent.futures模块

concurrent.futures是Python标准库中用于高级并发编程的模块，其中包含了ThreadPoolExecutor和ProcessPoolExecutor两个类，可以用于创建线程池和进程池。下面是使用ThreadPoolExecutor类实现多线程执行函数的代码示例：

import concurrent.futures

def func():
    print("Hello from thread", threading.current_thread().name)

# 创建线程池
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
    # 提交执行任务
    for i in range(5):
        executor.submit(func)

在上面的代码中，我们首先定义了一个名为func的函数，该函数将作为线程的执行函数。然后，我们使用with语句创建了一个ThreadPoolExecutor类型的线程池，并指定线程池的大小(max_workers=5)。接着，我们使用submit方法向线程池提交任务，调用func执行函数。

注意：

  • 在使用线程池执行函数时，我们不用显式地创建线程，线程池会自动处理线程的创建和销毁。
  • 同时创建多个线程时，由于Python具有全局解释器锁（GIL），无法利用多个CPU核心。如果要同时利用多个CPU核心，建议用多进程方式实现。

以上就是Python多线程执行函数的两种实现方法。在实际编程中，还需要考虑线程的同步、互斥等问题，以确保多线程程序的正确性和健壮性。

Tags: