本文详解如何在 python 中通过可调用类（`__call__`）替代全局变量实现线程安全、语义清晰的状态化回调函数，尤其适用于 kafka producer 等异步 api 场景。
在异步消息系统（如 Apache Kafka）中，生产者常需传入回调函数处理消息投递结果。典型写法是使用普通函数配合全局变量统计成功交付数：
callback_count = 0
def delivery_callback(error, message_payload):
if error:
print(f'ERROR: Kafka: {error}')
else:
global callback_count
callback_count += 1但该方式存在明显缺陷：全局状态污染、不可重入、难以测试、多线程下不安全。更专业的替代方案是使用 functor（即实现了 __call__ 的类），它天然封装状态，且支持实例隔离。
然而，若目标是复现“单例式全局计数”语义（即所有回调共享同一计数器，而非每个实例独立计数），不应依赖实例属性（self.count_callback），而应采用 类变量（class variable） —— 这才是 Python 中最接近“静态成员”的机制。
以下为推荐实现：
立即学习“Python免费学习笔记（深入）”；
class DeliveryCallbackCounter:
count_callback = 0 # ← 类变量：所有实例共享，等价于“静态变量”
def __call__(self, error, message):
if error:
print(f'ERROR: Kafka: Message delivery failure: {error}')
else:
DeliveryCallbackCounter.count_callback += 1 # ← 显式通过类名访问，确保语义明确
def __str__(self) -> str:
return f'DeliveryCallbackCounter: total successful deliveries = {DeliveryCallbackCounter.count_callback}'
@classmethod
def reset(cls):
"""提供显式重置接口，增强可控性"""
cls.count_callback = 0使用方式简洁直观：
# 创建任意数量的实例，它们共享同一计数器 counter1 = DeliveryCallbackCounter() counter2 = DeliveryCallbackCounter() producer.produce(topic="logs", value=b"msg1", callback=counter1) producer.produce(topic="logs", value=b"msg2", callback=counter2) producer.produce(topic="logs", value=b"msg3", callback=DeliveryCallbackCounter()) # 甚至可直接传临时实例 # 查看总计数（所有回调共同贡献） print(counter1) # 输出: DeliveryCallbackCounter: total successful deliveries = 3
⚠️ 注意事项：
避免 self.count_callback += 1：若在 __call__ 中误写为 self.count_callback += 1，Python 会创建同名实例属性并遮蔽类变量，导致计数失效；
显式使用 ClassName.attr 访问类变量 是最佳实践，语义清晰且防错；
-
如需线程安全（Kafka 回调可能在后台线程触发），应添加 threading.Lock：
import threading class ThreadSafeDeliveryCounter: count_callback = 0 _lock = threading.Lock() def __call__(self, error, message): if not error: with self._lock: ThreadSafeDeliveryCounter.count_callback += 1 若业务需要 每个 Producer 独立计数，则应使用实例变量（self.count_callback），此时 functor 的设计初衷——状态封装与复用——才真正发挥价值。
总结：Python 没有 static 关键字，但类变量 + 显式类名访问 + @classmethod 构成了功能完备的“静态状态”方案。相比全局函数，functor 提供了更好的封装性、可扩展性与可维护性，是构建健壮回调逻辑的首选范式。
