当前位置：首页 > article >正文

Python笔记之线程库threading

article 2024/11/6 9:16:37

Python笔记之线程库threading

在这里插入图片描述

参考博文
Python多线程笔记——简单函数版和类实现版

code review!

Python 的 threading 库用于在程序中创建和管理线程。线程允许程序并发执行多个任务。以下是 threading 库的详解和一些简洁示例。

基本概念

线程：在一个进程中，一个线程是执行指令的单独路径。
主线程：每个程序启动时都会有一个默认的主线程。
GIL（全局解释器锁）：Python 的线程受到 GIL 的限制，不能真正并行地运行 CPU 绑定的任务，但在 I/O 密集型任务中仍然可以提高性能。

重要类和方法

Thread 类：用于创建线程。
- start(): 开始线程活动。
- join(): 阻塞调用线程，直到被调用的线程终止。
- run(): 线程活动的方法。
Lock 类：用于线程间同步，防止竞争条件。
RLock 类：可重入锁，允许在同一线程中多次获得锁。
Condition 类：用于线程间通信。
Semaphore 类：控制对共享资源的访问。
Event 类：用于线程间信号通信。

简单示例

1. 创建并启动线程

import threading

def print_numbers():
    for i in range(5):
        print(i)

# 创建线程
thread = threading.Thread(target=print_numbers)

# 启动线程
thread.start()

# 等待线程完成
thread.join()

print("Thread has finished execution.")

2. 使用锁同步线程

import threading

counter = 0
lock = threading.Lock()

def increment_counter():
    global counter
    with lock:
        for _ in range(10000):
            counter += 1

threads = [threading.Thread(target=increment_counter) for _ in range(2)]

for thread in threads:
    thread.start()

for thread in threads:
    thread.join()

print(f"Final counter value: {counter}")

3. 创建自定义线程类

import threading

class MyThread(threading.Thread):
    def run(self):
        for i in range(5):
            print(f"Thread {self.name}: {i}")

# 实例化并启动自定义线程
thread = MyThread()
thread.start()
thread.join()