回调函数是一种通过函数指针(或引用)调用的函数,它在特定事件或条件发生时被另一个函数调用。回调函数的核心思想是将函数作为参数传递,以便在适当的时候执行自定义逻辑,常用于异步编程、事件驱动架构等场景。
业务场景及示例
1. 事件处理(如GUI按钮点击)
在图形界面中,用户点击按钮后触发特定操作。
# 示例:模拟事件处理器
class Button:
def __init__(self):
self.click_handlers = [] # 保存回调函数的列表
def add_click_handler(self, handler):
self.click_handlers.append(handler)
def click(self):
print("按钮被点击了!")
for handler in self.click_handlers:
handler() # 执行所有注册的回调函数
# 定义回调函数
def show_message():
print("弹出提示:操作成功!")
# 使用
button = Button()
button.add_click_handler(show_message)
button.add_click_handler(lambda: print("记录日志:按钮点击事件")) # 使用Lambda表达式
button.click()
# 输出:
# 按钮被点击了!
# 弹出提示:操作成功!
# 记录日志:按钮点击事件
2. 异步任务完成后的处理
例如,下载文件完成后自动处理数据。
import time
import threading
# 模拟异步下载
def download_file(url, callback):
def download_task():
print(f"开始下载 {url}...")
time.sleep(2) # 模拟耗时操作
data = f"下载内容:{url}"
callback(data) # 下载完成后调用回调处理数据
threading.Thread(target=download_task).start() # 启动新线程
# 定义回调函数:处理下载结果
def process_data(data):
print(f"处理数据: {data}")
# 使用
download_file("https://example.com/data.csv", process_data)
print("下载进行中,主线程继续运行...") # 非阻塞
# 输出:
# 开始下载 https://example.com/data.csv...
# 下载进行中,主线程继续运行...
# (2秒后)处理数据: 下载内容:https://example.com/data.csv
3. 定时任务调度
在指定时间后执行回调(如定时提醒)。
import time
from threading import Timer
# 定义定时器回调
def schedule_task(delay, callback):
def task():
time.sleep(delay)
callback()
Timer(0, task).start() # 启动定时线程
# 回调函数:定时任务内容
def remind():
print("提醒:会议将在5分钟后开始!")
# 使用
schedule_task(10, remind) # 10秒后触发提醒
print("定时器已设置,主线程继续工作...")
# 输出:
# 定时器已设置,主线程继续工作...
# (10秒后)提醒:会议将在5分钟后开始!
回调函数的优势
- 解耦逻辑:将触发逻辑与处理逻辑分离。
- 灵活性:允许动态扩展功能(如插件系统)。
- 异步支持:适用于I/O密集型任务(如网络请求)。
注意事项
过度使用回调可能导致“回调地狱”(嵌套层次深),此时可改用 Promise
或 async/await
(Python 的 asyncio
)。