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