为什么自定义带返回值的Python线程仅执行一次，未按预期周期性调用？

你的代码只执行一次get_account_data的核心原因是Python线程的生命周期限制：

• 每个Thread实例仅能执行一次run()方法：调用start()启动线程后，线程会跑完目标函数、进入终止状态，不会自动重复执行。
• 重复调用join()方法不会重新触发线程执行：join()的作用只是等待线程运行结束，线程终止后再调用join()只会直接返回你提前缓存的_return值，不会再运行目标函数。

你的代码实际执行流程为：

1. 主线程创建thread1实例并启动，子线程开始执行get_account_data，sleep 2秒后返回计算结果1，子线程进入终止状态
2. 进入while无限循环后，第一次调用thread1.join()会等待子线程结束，拿到返回值1并打印
3. 后续所有循环中调用thread1.join()时，因为子线程已经终止，会直接返回缓存的结果1，不会再触发get_account_data执行，因此函数仅运行一次。

如果你需要get_account_data周期性重复执行，有两种常用实现思路： #

方案1：将循环逻辑放在目标函数内 #

单个线程内循环执行目标逻辑，适合不需要单独控制每次执行周期的场景：

from threading import Thread
import time

def get_account_data(count, seconds=None):
    # 把重复执行逻辑放到函数内部
    while True:
        count += 1
        time.sleep(seconds)
        print(count) # 也可将结果存入队列供主线程读取

class ThreadWithReturn(Thread):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self._return = None

    def run(self):
        target = self._target
        if not target is None:
            self._return = target(*self._args, **self._kwargs)

    def join(self, *args, **kwargs):
        super().join(*args, **kwargs)
        return self._return

def main():
    count = 0
    thread1 = ThreadWithReturn(target=get_account_data, args=(count,), kwargs={'seconds':2})
    thread1.start()
    thread1.join()

if __name__ == '__main__':
    main()

方案2：循环内创建新线程实例 #

如果需要单独控制每次执行的参数、或每次执行需要独立的线程上下文，可以在循环内每次新建线程：

from threading import Thread
import time

def get_account_data(count, seconds=None):
    count += 1
    time.sleep(seconds)
    return count

class ThreadWithReturn(Thread):
    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self._return = None

    def run(self):
        target = self._target
        if not target is None:
            self._return = target(*self._args, **self._kwargs)

    def join(self, *args, **kwargs):
        super().join(*args, **kwargs)
        return self._return

def main():
    count = 0
    while(True):
        # 每次循环都新建、启动线程
        thread1 = ThreadWithReturn(target=get_account_data, args=(count,), kwargs={'seconds':2})
        thread1.start()
        count = thread1.join()
        print(count)

if __name__ == '__main__':
    main()

内容的提问来源于stack exchange，提问作者Stéphane REY