如何让FTP下载进程与Tkinter GUI同步运行？

对于FTP下载这类I/O密集型任务，多线程是最适配的方案——因为下载过程中大部分时间在等待网络响应，线程切换的开销极低，且不需要修改现有同步的FTP操作代码。异步IO（asyncio）反而需要将同步的ftplib调用包装到线程池中，复杂度更高，没必要舍近求远。

你的代码未能实现实时更新的核心问题有两个：

• 线程未实际启动：创建Thread对象后没有调用start()方法，导致下载任务仍在主线程执行，阻塞GUI。
• 跨线程更新GUI不安全：直接在下载线程中修改GUI元素违反tkinter（customtkinter基于tkinter）的线程安全规则，可能导致界面无响应或崩溃。

修正后的关键代码 #

1. GUI线程启动逻辑修复

修改App类的run方法，正确创建并启动线程，同时将任务参数单独传入：

def run(self):
    # 创建后台线程，daemon=True确保程序退出时线程自动终止
    threading.Thread(
        target=self.snidatadl.download_sniffers_data,
        args=(self.date_start, self.date_end, self.sniffers_list, self),
        daemon=True
    ).start()

2. 线程安全的GUI更新方法

修改App类的change_lbl方法，使用tkinter的after()机制确保GUI更新在主线程执行：

def change_lbl(self, text="DOWNLOADING..."):
    # after(0)将GUI更新任务调度到主线程的事件循环中
    self.after(0, lambda: self.lbl_download.configure(text=text))

3. 下载方法中的实时状态更新

调整download_sniffers_data方法，调用线程安全的更新方法，传递更具体的状态信息：

def download_sniffers_data(self, date_start, date_end, sniffers_list, gui):
    ftp = None  # 初始化ftp对象为None，避免finally块报错
    is_date_found = False
    ip_address = "your_ftp_ip"
    user_id = "your_user"
    psswd = "your_password"
    self.gui = gui

    try:
        ftp = FTP(ip_address)
        ftp.login(user=user_id, passwd=psswd)
        dir_names = ftp.nlst()
        gui.change_lbl("Connected to FTP server...")

        output_dir_name = self.make_date_dir()

        for s in sniffers_list:
            status_msg = f"Searching for sniffer \"{s}\""
            print(status_msg)
            gui.change_lbl(status_msg)
            
            if s in dir_names:
                ftp.cwd('/' + s + '/backup')
                folders_list = ftp.nlst()

                for folder in folders_list:
                    try:
                        date_temp = datetime.strptime(f'{folder[4: 6]}/{folder[2: 4]}/{folder[0:2]}',
                                                    '%d/%m/%y')
                        if date_start.date() <= date_temp.date() <= date_end.date():
                            ftp.cwd('/' + s + '/backup' + '/' + folder)
                            files_list = ftp.nlst()
                            gui.change_lbl(f"Scanning files in {folder}...")

                            for file in files_list:
                                try:
                                    file_array = file.split('-')
                                    string1 = f'{file_array[1][-2:]}.{file_array[1][2:4]}.{file_array[1][:2]} {file_array[2][:2]}:{file_array[2][2:]}'
                                    date_file = datetime.strptime(string1, '%d.%m.%y %H:%M')

                                    if date_start <= date_file <= date_end:
                                        is_date_found = True
                                        download_msg = f"Downloading {file}"
                                        print(download_msg)
                                        gui.change_lbl(download_msg)
                                        
                                        path = os.path.join(os.getcwd(), 'dir_output', output_dir_name, 'S' + s.strip('sni'))
                                        os.makedirs(path, exist_ok=True)  # 简化目录创建逻辑
                                        file_path = os.path.join(path, file)
                                        
                                        if not os.path.isfile(file_path):
                                            with open(file_path, 'wb') as localfile:
                                                ftp.retrbinary(f'RETR {file}', localfile.write, 1024)

                                except ValueError:
                                    pass
                            ftp.cwd('/' + s + '/backup')  # 回到上层目录，避免后续路径错误
                    except ValueError:
                        pass
                if not is_date_found:
                    msg = f'sniffer number: \"{s}\" no data found between the specified dates'
                    self.data_not_found_msgs.append(msg)
                    print(msg)
                is_date_found = False
            else:
                msg = f'sniffer number: \"{s}\" not found in the server'
                self.data_not_found_msgs.append(msg)
                print(msg)
        gui.change_lbl("Download completed!")

    except ConnectionError:
        error_msg = 'Unable to connect to server'
        print(error_msg)
        gui.change_lbl(error_msg)
    except ftplib.all_errors as e:
        error_msg = f'FTP connection error: {str(e)}'
        print(error_msg)
        gui.change_lbl(error_msg)
    finally:
        for msg in self.data_not_found_msgs:
            print(msg)
        if ftp:
            ftp.close()

额外优化点 #

• 使用os.path.join替代字符串拼接路径，避免跨平台问题。
• 用os.makedirs(path, exist_ok=True)简化目录创建逻辑。
• 在遍历文件夹后回到上层目录，避免后续路径错误。
• 捕获并显示具体的FTP错误信息，方便调试。
• 初始化ftp为None，确保finally块中关闭连接时不会报错。

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