python3多线程中如何改写run()函数

来源:站长联盟作者:半糖头衔:草根站长
导读:本期聚焦于小伙伴创作的《python3多线程中如何改写run()函数》,敬请观看详情,探索知识的价值。以下视频、文章将为您系统阐述其核心内容与价值。如果您觉得《python3多线程中如何改写run()函数》有用,将其分享出去将是对创作者最好的鼓励。

在python3的多线程编程中,threading模块是常用的实现工具,而run()函数是每个线程实例执行时的核心入口方法,默认情况下run()函数会执行传入线程的目标函数,若需要自定义线程的执行逻辑,就需要对run()函数进行改写。

python3多线程中如何改写run()函数

run()函数的基础作用

run()函数是Thread类的内置方法,当我们调用线程的start()方法时,python解释器会自动调用该线程实例的run()函数,执行其中的逻辑。如果没有改写run()函数,且创建线程时传入了target参数,那么run()函数会默认执行target对应的可调用对象。

改写run()函数的两种方式

方式一:继承Thread类重写run()方法

这是最常用的改写方式,我们创建一个继承自threading.Thread的子类,在子类中重写run()方法,将自定义的执行逻辑放在重写后的run()函数中即可。

示例代码如下:

import threading
import time

# 自定义线程类,继承Thread
class MyThread(threading.Thread):
    def __init__(self, thread_name, loop_count):
        # 调用父类构造器初始化
        super().__init__()
        self.thread_name = thread_name
        self.loop_count = loop_count

    # 重写run()函数
    def run(self):
        print(f"线程{self.thread_name}开始执行")
        for i in range(self.loop_count):
            print(f"线程{self.thread_name}执行第{i+1}次循环")
            time.sleep(0.5)
        print(f"线程{self.thread_name}执行结束")

if __name__ == "__main__":
    # 创建自定义线程实例
    t1 = MyThread("A", 3)
    t2 = MyThread("B", 2)
    # 启动线程,会自动调用重写的run()函数
    t1.start()
    t2.start()
    # 等待两个线程执行完成
    t1.join()
    t2.join()
    print("所有线程执行完成")

方式二:传入可调用对象到Thread构造器

如果不想自定义子类,也可以在创建Thread实例时,将自定义的可调用对象传给target参数,此时Thread类默认的run()函数会执行这个target对象,相当于间接改写了run()函数的执行逻辑。

示例代码如下:

import threading
import time

# 自定义可调用函数,作为线程执行的目标
def custom_task(thread_name, loop_count):
    print(f"线程{thread_name}开始执行")
    for i in range(loop_count):
        print(f"线程{thread_name}执行第{i+1}次循环")
        time.sleep(0.5)
    print(f"线程{thread_name}执行结束")

if __name__ == "__main__":
    # 创建线程时传入target和对应的参数
    t1 = threading.Thread(target=custom_task, args=("A", 3))
    t2 = threading.Thread(target=custom_task, args=("B", 2))
    # 启动线程
    t1.start()
    t2.start()
    # 等待线程完成
    t1.join()
    t2.join()
    print("所有线程执行完成")

改写run()函数的注意事项

  • 不要直接调用run()函数:直接调用run()函数不会创建新的线程,只会在当前线程中同步执行run()里的逻辑,必须调用start()方法才会启动新线程并执行run()
  • 参数传递规范:继承方式改写时,参数通过子类构造器传入并保存为实例属性;传入target方式时,参数通过args(元组)或kwargs(字典)传递给目标函数。
  • 线程逻辑独立性:run()函数中的逻辑应该尽量独立,避免多个线程同时修改同一个全局变量导致的竞态问题,必要时可以使用线程锁保证数据一致性。

两种方式的选择建议

如果线程的执行逻辑比较复杂,需要保存较多的线程相关状态,建议使用继承Thread类重写run()方法的方式,代码结构更清晰;如果只是简单的执行一个函数逻辑,不需要保存额外状态,使用传入target参数的方式更简洁,代码量更少。

python3多线程run()函数threading_module修改时间:2026-06-18 19:21:47

免责声明:​ 已尽一切努力确保本网站所含信息的准确性。网站内容多为原创整理与精心编撰,观点力求客观中立。本站旨在免费分享,内容仅供个人学习、研究或参考使用。若引用了第三方作品,版权归原作者所有。如内容涉及您的权益,请联系我们处理。
内容垂直聚焦
专注技术核心技术栏目,确保每篇文章深度聚焦于实用技能。从代码技巧到架构设计,为用户提供无干扰的纯技术知识沉淀,精准满足专业提升需求。
知识结构清晰
覆盖从开发到部署的全链路。AI、前端、编程、数据库、服务器、建站、系统层层递进,构建清晰学习路径,帮助用户系统化掌握开发与运维所需的核心技术。
深度技术解析
拒绝泛泛而谈,深入技术细节与实践难点。无论是数据库优化还是服务器配置,均结合真实场景与代码示例进行剖析,致力于提供可直接应用于工作的解决方案。
专业领域覆盖
精准对应开发生命周期。从前端界面到后端编程,从数据库操作到服务器运维,形成完整闭环,一站式满足全栈工程师和运维人员的技术需求。
即学即用高效
内容强调实操性,步骤清晰、代码完整。用户可根据教程直接复现和应用于自身项目,显著缩短从学习到实践的距离,快速解决开发中的具体问题。
持续更新保障
专注既定技术方向进行长期、稳定的内容输出。确保各栏目技术文章持续更新迭代,紧跟主流技术发展趋势,为用户提供经久不衰的学习价值。