博客

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

  • Post category:Python

Python多线程是一种并发编程的实现方式，它能够将一个程序的不同部分同时运行，提高程序的执行效率。

以下是实现Python多线程执行函数的完整攻略：

1.导入模块

在使用多线程之前需要先导入threading模块，该模块提供了多线程处理的相关方法和类。

import threading

2.定义线程执行函数

接下来需要定义一个线程执行的函数，可以在函数内部实现需要多线程执行的业务逻辑。

def thread_func(arg1, arg2):
    # 执行需要多线程处理的业务逻辑
    pass

3.创建线程

创建线程可以使用threading.Thread类，可以在创建过程中指定线程执行对应的函数和参数。

# 创建一个线程，指定线程的执行函数为thread_func，参数为arg1和arg2
t = threading.Thread(target=thread_func, args=(arg1, arg2))

4.启动线程

创建线程后需要使用start()方法启动线程，该方法会开启一个新的线程来执行thread_func函数。

# 启动线程
t.start()

5.等待线程执行完成

如果需要等待线程执行完成，可以使用join()方法，该方法会阻塞当前线程，直到指定的线程执行完成。

# 等待线程执行完成
t.join()

上述攻略中的代码示例：

示例1

在这个示例中，我们定义了一个线程执行函数download_file()，该函数的功能是从指定的URL下载文件并保存到本地文件系统中。

import threading
import requests

def download_file(url, file_name):
    response = requests.get(url)
    with open(file_name, "wb") as f:
        f.write(response.content)
    print(f"{file_name} download completed")

url1 = "https://cdn.pixabay.com/photo/2021/08/18/20/32/coffee-6552819_1280.jpg"
url2 = "https://cdn.pixabay.com/photo/2021/08/11/13/53/bee-6530566_1280.jpg"

t1 = threading.Thread(target=download_file, args=(url1, "coffee.jpg"))
t2 = threading.Thread(target=download_file, args=(url2, "bee.jpg"))

t1.start()
t2.start()

t1.join()
t2.join()

print("all done")

在这个例子中，我们定义了两个线程，分别从不同的URL下载文件，因为下载过程中会有网络等待，所以可以同时执行这两个线程，提高下载速度。

示例2

在这个示例中，我们定义了一个线程执行函数count_num()，该函数的功能是打印指定范围内的数字。

import threading

def count_num(start, end):
    for i in range(start, end):
        print(i)

t1 = threading.Thread(target=count_num, args=(1, 100000))
t2 = threading.Thread(target=count_num, args=(100001, 200000))

t1.start()
t2.start()

t1.join()
t2.join()

print("all done")

在这个例子中，我们定义了两个线程，分别打印数字1到100000和100001到200000。这些数字并不需要互相依赖，所以可以让两个线程同时执行，提高打印速度。

Tags: