求助：基于Python多线程实现单行打印的代码问题

我看你想通过多线程实现单行实时打印的功能，先梳理下现有代码里的问题，再给你可行的修复方案～

首先看你给出的Printer线程类，里面有两个明显的笔误：

1. __init__方法里重复赋值了self.count1，漏掉了self.count2 = count2
2. run方法的格式化字符串里，把count2写成了count1，导致打印内容完全不对

另外，多线程环境下直接操作sys.stdout会有线程安全问题——如果多个打印线程同时写入，会导致输出内容错乱。还有，你的count1和count2如果是会被其他线程修改的变量，也需要加锁保护，避免出现数据不一致的情况。

下面是修复后的完整实现：

1. 修正后的Printer类（带线程安全锁） #

import threading
import sys
import time

class Printer(threading.Thread):
    def __init__(self, count_lock, count1, count2):
        super().__init__()  # 用super()更简洁地调用父类构造方法
        self.count_lock = count_lock
        self.count1 = count1
        self.count2 = count2
        self._stop_event = threading.Event()  # 用于优雅停止线程

    def stop(self):
        self._stop_event.set()

    def run(self):
        while not self._stop_event.is_set():
            # 加锁确保读取count1和count2时不会被其他线程修改
            with self.count_lock:
                to_print = '\rCount1: {} Count2: {}'.format(self.count1, self.count2)
            # 加锁确保stdout写入时不会被其他线程打断
            with threading.Lock():
                sys.stdout.write(to_print)
                sys.stdout.flush()
            time.sleep(1)  # 缩短间隔方便测试，可改回5秒

2. 完整的线程池实现（用于管理打印线程） #

class ThreadPool:
    def __init__(self, num_threads, count_lock, count1, count2):
        self.threads = []
        # 创建指定数量的打印线程
        for _ in range(num_threads):
            printer = Printer(count_lock, count1, count2)
            self.threads.append(printer)
            printer.start()

    def stop_all(self):
        # 优雅停止所有线程
        for thread in self.threads:
            thread.stop()
        # 等待所有线程结束
        for thread in self.threads:
            thread.join()

3. 测试代码（模拟多线程更新计数） #

def main():
    # 全局锁，保护count1和count2的读写操作
    count_lock = threading.Lock()
    count1 = 0
    count2 = 0

    # 启动线程池，比如创建2个打印线程
    pool = ThreadPool(2, count_lock, count1, count2)

    # 模拟其他线程修改count1和count2的值
    def update_counts():
        nonlocal count1, count2
        for _ in range(10):
            with count_lock:
                count1 += 1
                count2 += 2
            time.sleep(0.5)
        # 计数更新完成后停止所有打印线程
        pool.stop_all()

    update_thread = threading.Thread(target=update_counts)
    update_thread.start()
    update_thread.join()

if __name__ == "__main__":
    main()

关键说明 #

• 线程安全锁：用count_lock保护count1和count2的读写，避免多线程同时修改导致数据错误；用单独的锁保护sys.stdout的写入，防止多个线程同时打印造成输出混乱。
• 优雅停止：通过threading.Event实现线程的优雅停止，避免直接强制终止线程带来的资源泄漏问题。
• 代码修正：修复了原代码中的笔误，确保count2能被正确赋值和打印。

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