自定义Python Thread类中run()方法的参数传递问题

问题1：自定义MyThread类继承Thread并重写run()方法时，能否像回调函数那样访问通过args传入的线程参数？ #

不能直接在run()方法的参数列表里接收args内容。Thread类的args参数是给target回调函数设计的，当你重写run()方法后，默认调用target并传入args/kwargs的逻辑会被覆盖，args不会自动传递给你重写的run()方法。

要获取args里的参数，可直接访问线程实例的self.args属性（它会保存传入的参数元组），示例代码：

from threading import Thread
from queue import Queue

class MyThread(Thread):
    def run(self) -> None:
        # 从self.args中取出传入的queue参数
        queue = self.args[0]
        print(f"线程中获取到队列: {queue}")

queue = Queue()
myThread = MyThread(args=(queue,))
myThread.start()  # 注意要加括号调用start方法

问题2：如何在自定义Thread类中使用kwargs？ #

和args类似，Thread的kwargs参数默认给target回调用。重写run()后，可通过self.kwargs属性访问传入的参数字典。注意创建线程时，kwargs需要传入字典（原代码里的{'queue',queue}是集合，属于错误写法，应改为{'queue': queue}）。

基础用法示例：

from threading import Thread
from queue import Queue

class MyThread(Thread):
    def run(self) -> None:
        # 从self.kwargs中取出key为'queue'的参数
        queue = self.kwargs.get('queue')
        if queue:
            print(f"线程中通过kwargs获取到队列: {queue}")

queue = Queue()
myThread = MyThread(kwargs={'queue': queue})
myThread.start()

如果想让代码更直观，也可以在__init__中主动提取kwargs参数为实例变量：

from threading import Thread
from queue import Queue
from typing import Mapping, Any, Callable, Optional

class MyThread(Thread):
    def __init__(self, group: Optional[None] = None, target: Optional[Callable[..., object]] = None,
                 name: Optional[str] = None, args: Iterable[Any] = (), kwargs: Optional[Mapping[str, Any]] = None,
                 daemon: Optional[bool] = None):
        super().__init__(group, target, name, args, kwargs, daemon=daemon)
        # 从kwargs中提取需要的参数
        self.queue = kwargs.get('queue') if kwargs else None

    def run(self) -> None:
        if self.queue:
            print(f"线程中通过实例变量获取到队列: {self.queue}")

queue = Queue()
myThread = MyThread(kwargs={'queue': queue})
myThread.start()

问题3：将queue直接传入MyThread并保存为实例变量是否合理？ #

非常合理，甚至是推荐做法。这种方式比依赖Thread自带的args/kwargs更清晰，可读性更高，还能方便添加类型提示，避免从元组/字典中取值时的索引或键名错误。

原代码的__init__有几处小问题需要修正：

• args的默认值不能用...，应改为空元组()
• queue作为自定义参数，需调整位置避免和父类参数冲突
• 调用父类__init__时要注意参数顺序和关键字参数用法

修正后的示例代码：

from threading import Thread
from queue import Queue
from typing import Mapping, Any, Callable, Optional

class MyThread(Thread):
    def __init__(self, queue: Queue, group: Optional[None] = None,
                 target: Optional[Callable[..., object]] = None, name: Optional[str] = None,
                 args: Iterable[Any] = (), kwargs: Optional[Mapping[str, Any]] = None,
                 *, daemon: Optional[bool] = None) -> None:
        self.queue = queue
        # 调用父类构造方法，明确关键字参数避免顺序错误
        super().__init__(group=group, target=target, name=name, args=args, kwargs=kwargs, daemon=daemon)

    def run(self) -> None:
        # 直接使用self.queue进行业务操作
        print(f"线程中使用实例变量队列: {self.queue}")
        self.queue.put("test item")

queue = Queue()
myThread = MyThread(queue=queue)
myThread.start()
# 验证队列数据
print(f"主线程获取队列数据: {queue.get()}")

这种方式的优势：

• 代码意图明确，一眼就能看出线程依赖queue
• 类型检查工具（如mypy）能更好地做类型校验
• 避免从args/kwargs取值时的索引错误或键名拼写错误

内容的提问来源于stack exchange，提问作者paul_schaefer