Python3 多线程

在 Python 中，多线程是一种实现并发执行的方式。多线程可以提高程序的效率和响应性，尤其是在处理 I/O 密集型任务时。本章将详细介绍如何使用 Python 的内置模块 threading 来创建和管理多线程。

Python 线程的基本概念

什么是线程？

线程是操作系统能够进行运算调度的最小单位。它被包含在进程之中，是进程中的实际运作单位。一个进程至少有一个线程，也可以有多个线程。每个线程都有自己的栈空间，并且可以独立运行。

Python 中的线程

Python 提供了两种线程模型：_thread 和 threading 模块。由于 _thread 模块过于底层，通常推荐使用 threading 模块来处理线程相关的操作。threading 模块提供了更高级、更易用的接口来创建和管理线程。

创建和启动线程

使用 threading 模块创建线程

首先需要导入 threading 模块，然后创建一个 Thread 类的实例，指定线程的函数和参数。最后调用 start() 方法来启动线程。

// www.javascriptcn.com code example
import threading

def my_function(arg):
    print(f"线程正在运行: {arg}")

# 创建线程实例
thread = threading.Thread(target=my_function, args=(123,))
# 启动线程
thread.start()

线程的生命周期

线程从创建开始，经过初始化、就绪、运行、阻塞到结束几个阶段。线程的状态可以通过 is_alive() 方法检查。

// www.javascriptcn.com code example
import time
import threading

def my_function():
    time.sleep(5)  # 模拟耗时操作
    print("线程已经完成")

# 创建并启动线程
thread = threading.Thread(target=my_function)
thread.start()

# 主线程等待子线程完成
thread.join()
print("主线程继续执行")

线程同步

使用锁进行同步

在多线程环境中，当多个线程访问共享资源时，可能会出现数据不一致的问题。这时可以使用锁来确保同一时间只有一个线程能访问该资源。

// www.javascriptcn.com code example
import threading

counter = 0
lock = threading.Lock()

def increment():
    global counter
    for _ in range(100000):
        lock.acquire()
        try:
            counter += 1
        finally:
            lock.release()

# 创建多个线程
threads = []
for _ in range(5):
    thread = threading.Thread(target=increment)
    threads.append(thread)
    thread.start()

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

print(f"最终计数器值为: {counter}")

使用条件变量

除了锁之外，还可以使用条件变量来控制线程间的协作。

// www.javascriptcn.com code example
import threading

class SharedResource:
    def __init__(self):
        self.value = 0
        self.condition = threading.Condition()

    def increment(self):
        with self.condition:
            self.value += 1
            self.condition.notify_all()

    def decrement(self):
        with self.condition:
            while self.value == 0:
                self.condition.wait()
            self.value -= 1
            self.condition.notify_all()

shared_resource = SharedResource()

def producer():
    for _ in range(5):
        shared_resource.increment()
        print(f"生产者增加值: {shared_resource.value}")

def consumer():
    for _ in range(5):
        shared_resource.decrement()
        print(f"消费者减少值: {shared_resource.value}")

# 创建线程
producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer)

# 启动线程
producer_thread.start()
consumer_thread.start()

# 等待线程完成
producer_thread.join()
consumer_thread.join()

守护线程

守护线程是在后台运行的线程，它们不会阻止程序退出。如果所有的非守护线程都结束了，那么整个进程就会退出，即使守护线程还在运行。

// www.javascriptcn.com code example
import threading
import time

def daemon_task():
    while True:
        print("守护线程正在运行...")
        time.sleep(1)

daemon = threading.Thread(target=daemon_task, daemon=True)
daemon.start()

# 主线程等待一段时间后退出
time.sleep(5)
print("主线程结束")

总结

通过本章的学习，你应该掌握了 Python 中多线程的基本概念和用法。理解了如何创建和启动线程，如何使用锁和条件变量来同步线程，以及如何利用守护线程来控制程序的退出。这些知识是构建复杂并发应用的基础。