python多线程教学

Python中实现多线程有两种方式：使用thread模块或使用threading模块。由于thread模块已经被弃用，本教程将使用threading模块。

1. 创建线程

要创建一个线程，需要定义一个函数作为线程的执行体，并使用threading.Thread类创建线程对象。

import threading

def print_numbers():
    for i in range(1, 6):
        print(i)

t = threading.Thread(target=print_numbers)

2. 启动线程

创建线程对象后，需要调用start()方法启动线程。线程启动后，会自动调用执行体函数。

t.start()

3. 等待线程结束

可以使用join()方法等待线程执行完毕。如果不调用join()方法，主线程可能会在子线程执行完之前结束，从而导致子线程被迫关闭。

t.join()

4. 传递参数

可以使用args参数传递参数给线程的执行体函数。

import threading

def print_numbers(start, end):
    for i in range(start, end+1):
        print(i)

t = threading.Thread(target=print_numbers, args=(1, 5))
t.start()
t.join()

5. 线程同步

线程同步是指多个线程在执行时需要相互协调，以避免冲突和不一致性的问题。Python提供了多种同步机制，包括锁、信号量、事件等。

下面是一个使用锁实现线程同步的例子：

import threading

balance = 0
lock = threading.Lock()

def deposit(amount):
    global balance
    lock.acquire()
    try:
        balance += amount
    finally:
        lock.release()

def withdraw(amount):
    global balance
    lock.acquire()
    try:
        balance -= amount
    finally:
        lock.release()

t1 = threading.Thread(target=deposit, args=(100,))
t2 = threading.Thread(target=withdraw, args=(50,))
t1.start()
t2.start()
t1.join()
t2.join()
print(balance)

6. 线程池

线程池是一种管理线程的机制，可用于限制线程的数量，以及重复使用已创建的线程，从而减少线程创建和销毁的开销。

Python中可以使用concurrent.futures模块的ThreadPoolExecutor类实现线程池。该类提供了submit()方法，用于将函数提交给线程池执行，并返回Future对象，可用于获取函数的执行结果。

下面是一个使用线程池实现并发下载的例子：

import requests
import concurrent.futures

urls = ['https://www.python.org/', 'https://www.baidu.com/', 'https://www.bing.com/']

def download(url):
    response = requests.get(url)
    return response.content

with concurrent.futures.ThreadPoolExecutor(max_workers=3) as executor:
    futures = [executor.submit(download, url) for url in urls]

    for future in concurrent.futures.as_completed(futures):
        content = future.result()
        print(len(content))

以上就是Python多线程的基本教学。需要注意的是，多线程编程需要特别注意线程安全和死锁等问题，建议在实际开发中使用线程池等高级工具，以避免这些问题。