Python回调函数详解：从原理到异步处理实战

Noah

发布时间：2026-10-15| 8人浏览过

原创

本文深入解析Python中回调函数的核心概念，通过旅馆叫醒服务的类比阐明其注册与执行机制。重点探讨回调在提升代码灵活性方面的优势，并详细演示如何在异步场景中处理上下文依赖，包括使用绑定方法、闭包以及协程（yield/send）实现状态保持与结果回调，帮助开发者掌握高阶函数调用技巧。

摘要

本文主要介绍Python语言中回调函数（callback）的相关知识与应用。

什么是回调函数

在程序运行过程中，应用程序通常会通过API调用库中预先准备好的函数。然而，某些库函数却要求应用先传入一个函数，以便在适当时机调用该函数以完成特定任务。这个被传入、随后又被调用的函数，即被称为回调函数（callback function）。

例如：

假设一家旅馆提供叫醒服务，但要求旅客自行决定叫醒的方式。方式可以是拨打客房电话，也可以是派服务员敲门，甚至对于睡眠较深担心误事的旅客，还可以要求向其头上浇一盆水。在此场景中，“叫醒”这一行为由旅馆提供，相当于库函数；而叫醒的具体方式由旅客决定并告知旅馆，这相当于回调函数。旅客告知旅馆如何执行叫醒的动作，即将回调函数传入库函数的过程，被称为登记回调函数（to register a callback function）。

可以看出，回调函数通常与应用处于同一抽象层，因为具体传入何种回调函数是在应用级别决定的。因此，回调过程表现为一个高层调用底层，底层再反过来调用高层的过程。这应当是回调机制最早的应用场景，也是其得名的原因。

回调机制的优势

回调机制提供了极高的灵活性。我们将图中的库函数改称为中间函数，因为回调不仅限于应用与库之间的交互。在任何需要获得类似灵活性的场合，都可以利用回调。有同学可能会认为回调仅是函数间的调用，但两者之间存在一个关键区别：

在回调中，我们通过某种方式将回调函数作为参数传入中间函数。可以这样理解：在传入回调函数之前，中间函数的功能是不完整的。换言之，程序可以在运行时，通过登记不同的回调函数，来决定或改变中间函数的行为。这使得回调比简单的函数调用灵活得多。

#回调函数1
#生成一个2k形式的偶数
def double(x):
    return x * 2
    
#回调函数2
#生成一个4k形式的偶数
def quadruple(x):
    return x * 4
 
callback_demo.py`
 
from even import *
 
#中间函数
#接受一个生成偶数的函数作为参数
#返回一个奇数
def getOddNumber(k, getEvenNumber):
    return 1 + getEvenNumber(k)
    
#起始函数，这里是程序的主函数
def main():    
    k = 1
    #当需要生成一个2k+1形式的奇数时
    i = getOddNumber(k, double)
    print(i)
    #当需要一个4k+1形式的奇数时
    i = getOddNumber(k, quadruple)
    print(i)
    #当需要一个8k+1形式的奇数时
    i = getOddNumber(k, lambda x: x * 8)
    print(i)
    
if __name__ == "__main__":
    main()

异步处理有关的回调函数

def apply_ascyn(func, args, callback):
    """ 
    func 函数的是处理的函数
    args 表示的参数
    callback 表示的函数处理完成后的 该执行的动作
    """
    result = func(*args)
    callback(result)
 
def add(x, y):
    return x + y
 
def print_result(result):
    print(result)
 
apply_ascyn(add, (2, 3), callback=print_result)

在上述示例中，print_result只能接收一个result参数，无法传入其他信息。当希望回调函数访问其他变量或特定环境中的变量值时，会遇到问题。

使用一个绑定方法来代替这个简单函数。

def appy_async(func, args, *, callback):
    result = func(*args)
    #异步执行的函数 同时将执行后返回到这个早从这个函数跳出去
    callback(result)
 
def add(x ,y):
    return x + y
 
class ResultHandler(object):
    def __init__(self):
        self.sequence = 0
 
    def handle(self, result):
        self.sequence += 1
        print("[{}] Got: {}".format(self.sequence, result))
 
resultHandler = ResultHandler()
appy_async(add, (2,3), callback=resultHandler.handle)

使用闭包代替上面的类来实现

def apply_async(func, args, *, callback):
    result = func(*args)
    callback(result)
 
def add(x ,y):
    return x + y
 
def make_handler():
    sequence = 0
    def handler(result):
        nonlocal sequence
        sequence += 1
        print("[{}] Got:{}".format(sequence, result))
    return handler
 
handler = make_handler()
apply_async(add, (2,3), callback=handler)

使用协程来完成异步操作

def apply_async(func, args, *, callback):
    result = func(*args)
    callback(result)
 
def add(x, y):
    return x + y
 
def make_handler():
    sequence = 0
    while True:
        result = yield
        sequence += 1
        print("[{}] Got:{}".format(sequence, result))
 
handle = make_handler()
next(handle)
 
apply_async(add, (2,3), callback=handle.send)

博文参考:

python3回调函数(callback) - 知乎