Python threading.current_thread() 当前正在执行的线程对象

说明

《Python 教程》持续更新中，提供建议、纠错、催更等加作者微信: gairuo123（备注：pandas教程）和关注公众号「盖若」ID: gairuo。跟作者学习，请进入 Python学习课程。欢迎关注作者出版的书籍：《深入浅出Pandas》和《Python之光》。

threading.current_thread() 是 Python threading 模块中的一个函数，用于获取当前正在执行的线程对象。这个函数在多线程编程中非常有用，可以帮助我们识别当前运行的线程。它返回当前对应调用者的控制线程的 Thread 对象。如果调用者的控制线程不是利用 threading 创建，会返回一个功能受限的虚拟线程对象。函数 currentThread 是此函数的已弃用别名。

使用场景

threading.current_thread() 是 Python threading 模块中的一个函数，用于获取当前正在执行的线程对象。这个函数在多线程编程中非常有用，可以帮助我们识别当前运行的线程。

使用场景：

调试：在多线程程序中，识别当前线程对于调试和日志记录非常有用。
线程管理：在需要对特定线程执行操作时，可以通过这个函数获取线程对象。
线程标识和跟踪：在多线程环境中，能够明确知道当前正在执行的是哪个线程。
日志记录：在日志中记录当前操作所属的线程，便于问题排查和跟踪。
基于线程的条件执行：根据当前线程的某些属性（如线程名）来决定执行不同的逻辑。

示例

以下是一个简单的使用示例代码：

import threading

def worker():
    print(f"Current thread: {threading.current_thread().name}")

# 创建并启动两个线程
thread1 = threading.Thread(target=worker, name='Thread-1')
thread2 = threading.Thread(target=worker, name='Thread-2')

thread1.start()
thread2.start()

thread1.join()
thread2.join()

再如：

import threading
import time

def worker():
    current_thread = threading.current_thread()
    print(f"当前线程: {current_thread.name}")
    time.sleep(2)

threads = []

for i in range(3):
    t = threading.Thread(target=worker)
    t.start()
    threads.append(t)

for t in threads:
    t.join()

案例

假设我们有一个多线程下载任务的程序，不同的线程负责下载不同的文件。我们可以使用 threading.current_thread() 来获取当前线程，并根据线程的名称或其他标识来决定下载的文件路径和处理方式。

import threading
import requests

def download_file(url, save_path):
    current_thread = threading.current_thread()
    print(f"线程 {current_thread.name} 开始下载: {url}")
    response = requests.get(url)
    with open(save_path, 'wb') as file:
        file.write(response.content)
    print(f"线程 {current_thread.name} 下载完成: {url}")

threads = []
urls = [
    "https://example.com/file1.txt",
    "https://example.com/file2.txt",
    "https://example.com/file3.txt"
]

for i, url in enumerate(urls):
    thread_name = f"下载线程 {i}"
    t = threading.Thread(target=download_file, args=(url, f"file_{i}.txt"), name=thread_name)
    t.start()
    threads.append(t)

for t in threads:
    t.join()

参考

https://docs.python.org/zh-cn/3/library/threading.html#threading.current_thread

< threading.active_count() 当前活动线程数 Python 模块 threading 基于线程的并行 threading.enumerate() 当前所有活动线程对象列表 >

更新时间：June 30, 2024, 3:20 p.m. 标签：python threading 多线程