当前位置：首页 > news >正文

回调函数的作用与举例（Python版）

news 2025/11/6 10:13:06

函数回调的作用

函数回调（Callback）是指将一个函数作为参数传递给另一个函数，当特定事件或条件满足时，被传递的函数会被调用。其核心作用包括：

解耦逻辑：将 “事件触发” 与 “事件处理” 分离，使代码更灵活、可复用。
异步处理：在异步操作（如网络请求、定时器）完成后，通过回调通知结果。
事件驱动：响应特定事件（如用户点击、数据到达）时执行自定义逻辑。

回调函数基础举例

以 “计算器” 为例，将运算逻辑（加、减）作为回调函数传递给主函数：

python

# 回调函数：加法
def add(a, b):return a + b# 回调函数：减法
def subtract(a, b):return a - b# 主函数：接收回调函数并执行
def calculate(a, b, callback):return callback(a, b)# 使用回调
print(calculate(5, 3, add))      # 输出：8
print(calculate(5, 3, subtract)) # 输出：2

回调函数处理不同消息机制的写法与实例

消息机制通常指 “事件源产生消息，回调函数处理消息” 的模式，常见场景包括 GUI 事件、网络消息、状态通知等。

1. GUI 事件消息（以 Python Tkinter 为例）

机制：用户操作（点击按钮、输入文本）产生事件消息，回调函数响应事件。

python

import tkinter as tk
from tkinter import messagebox# 回调函数：处理按钮点击消息
def on_button_click():messagebox.showinfo("消息", "按钮被点击了！")# 回调函数：处理文本输入消息
def on_text_change(event):print(f"输入内容：{event.widget.get()}")# 创建GUI
root = tk.Tk()
root.title("消息机制示例")# 绑定按钮点击消息到回调
btn = tk.Button(root, text="点击我", command=on_button_click)
btn.pack(pady=10)# 绑定文本输入消息到回调（带事件参数）
entry = tk.Entry(root)
entry.pack(pady=10)
entry.bind("<KeyRelease>", on_text_change)  # 键盘释放时触发root.mainloop()

2. 网络消息（以 HTTP 请求回调为例）

机制：网络请求完成后，通过回调处理响应消息（同步 / 异步均可，异步更常见）。

python

import requests
from threading import Thread# 回调函数：处理网络响应消息
def handle_response(response):if response.status_code == 200:print(f"响应内容：{response.text[:50]}...")else:print(f"请求失败，状态码：{response.status_code}")# 异步发送请求，完成后调用回调
def async_request(url, callback):def _request():response = requests.get(url)callback(response)  # 网络消息处理Thread(target=_request).start()# 发送请求并指定回调
async_request("https://api.github.com", handle_response)
print("请求已发送，等待响应...")  # 主线程不阻塞

3. 状态机消息（以设备状态变更为例）

机制：设备状态（如 “启动”“运行”“故障”）变更时，通过回调通知状态消息。

python

# 状态回调函数：处理不同状态消息
def on_start():print("设备启动：初始化传感器...")def on_running(speed):print(f"设备运行：当前速度 {speed} rpm")def on_error(code):print(f"设备故障：错误码 {code}，请检修！")# 设备状态机：根据状态触发对应回调
class Device:def __init__(self):self.callbacks = {"start": on_start,"running": on_running,"error": on_error}def set_state(self, state, *args):if state in self.callbacks:self.callbacks[state](*args)  # 传递状态参数# 模拟设备状态变更
device = Device()
device.set_state("start")         # 触发on_start
device.set_state("running", 3000) # 触发on_running(3000)
device.set_state("error", 502)    # 触发on_error(502)

4. 消息队列（以生产者 - 消费者模型为例）

机制：生产者发送消息到队列，消费者通过回调函数处理队列中的消息。

python

from queue import Queue
import time
import threading# 回调函数：处理队列消息
def process_message(msg):print(f"处理消息：{msg}，耗时1秒")time.sleep(1)  # 模拟处理耗时# 消费者：循环从队列取消息并调用回调
def consumer(queue, callback):while True:msg = queue.get()if msg == "exit":breakcallback(msg)queue.task_done()# 生产者：向队列发送消息
def producer(queue):messages = ["消息1", "消息2", "消息3", "exit"]for msg in messages:queue.put(msg)time.sleep(0.5)  # 模拟间隔发送# 启动队列和线程
q = Queue()
threading.Thread(target=consumer, args=(q, process_message), daemon=True).start()
producer(q)
q.join()  # 等待所有消息处理完成