淄博张店网站建设,全网搜索,霸州做网站shijuewang,大上海小程序开发一. 前言
在Python中#xff0c;回调函数是指在一个函数执行完成后#xff0c;调用另一个函数的过程。通常情况下#xff0c;回调函数作为参数传递给原始函数#xff0c;原始函数在执行完自己的逻辑后#xff0c;会自动调用回调函数并将结果作为参数传递给它。
二. 回调…一. 前言
在Python中回调函数是指在一个函数执行完成后调用另一个函数的过程。通常情况下回调函数作为参数传递给原始函数原始函数在执行完自己的逻辑后会自动调用回调函数并将结果作为参数传递给它。
二. 回调函数基本使用
以下是在Python中设置回调函数的基本步骤
定义回调函数确定回调函数的参数列表和返回值如果有。在原始函数中将回调函数作为参数传递给需要回调的函数。在原始函数内部的适当位置调用回调函数将需要传递的参数传递给它。
例如假设我们需要设置一个回调函数来处理异步操作的结果可以按如下方式进行设置
# 定义回调函数
def callback(result):print(Callback function is called with result: , result)# 异步函数需要传入回调函数
def async_function(param1, param2, callback):# 进行异步操作result param1 param2# 异步操作完成后调用回调函数callback(result)# 调用异步函数并传入回调函数
async_function(1, 2, callback)运行结果 在上面的代码中我们先定义了一个回调函数callback然后在异步函数async_function中将该函数作为参数传递并在异步操作完成后调用回调函数将操作结果传递给它。
通常情况下我们会将回调函数定义为一个可调用对象也就是实现了__call__方法的类对象。使用这种方式可以更加灵活地定义回调函数并且可以把一些状态或上下文信息存储在对象中在回调函数中使用。
三. 进阶 - 使用functools.partial传递函数
1. functools.partial基本介绍
functools.partial 是 Python 标准库中的一个函数用来部分应用一个函数partial application也就是固定函数的一部分参数返回一个新的函数。 partial 函数的用法如下
functools.partial(func, *args, **kwargs)其中func 是要部分应用的函数*args 和 **kwargs 是要固定的参数。
具体来说partial 函数会返回一个新的函数对象这个新的函数对象跟原来的函数对象是相似的但是将部分参数固定下来了相当于原来的函数变成了一个带有默认参数的函数。我们可以用这个新的函数对象来调用原来的函数而不必传入那些已经固定的参数。
下面是一个简单的示例代码演示如何使用 partial 函数
import functools# 定义一个简单的加法函数
def add(a, b):return a b# 固定 add 函数的第一个参数
add2 functools.partial(add, 2)# 调用 add2 函数
print(add2(3)) # 输出5在上面的示例代码中我们定义了一个简单的加法函数 add然后使用 partial 函数将 add 函数的第一个参数固定为 2得到一个新的函数对象 add2。接下来我们使用 add2 函数来计算 23 的结果并将结果输出到控制台。
使用 partial 函数的好处是可以更方便地定义新的函数避免代码重复。比如如果我们想定义一个加 3、加 4、加 5 的函数可以使用 partial 来实现而不必写多个类似的函数。
add3 functools.partial(add, 3)
add4 functools.partial(add, 4)
add5 functools.partial(add, 5)print(add3(2)) # 输出5
print(add4(2)) # 输出6
print(add5(2)) # 输出7在上面的示例代码中使用 partial 函数分别定义了 3 个新的函数 add3、add4、add5分别将加数固定为 3、4、5然后使用这些新的函数计算 23、24、25 的结果并将结果输出到控制台。
2. functools.partial进阶使用示例代码
接下来我们看一个socket连接成功之后调用回调函数的例子
1. 启动一个socket server服务
import json
import os
import socket
import threading
import time
import sys
import tracebackHOST 127.0.0.1 # 服务器IP地址
PORT 8000 # 服务器端口号
BACKLOG 5 # 服务器监听队列大小即最多同时接收多少个客户端连接
RECONNECT_INTERVAL 5 # 重连间隔单位秒def start_server():print(os.getpid())while True:try:# 创建一个 TCP/IP socket 对象server_socket socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 绑定服务器 IP 地址和端口号server_socket.bind((HOST, PORT))# 开始监听客户端连接请求server_socket.listen(BACKLOG)print(服务器启动监听端口%s % PORT)while True:# 等待客户端连接print(等待客户端连接...)try:client_socket, client_address server_socket.accept()threading.Thread(targetsend_msg, args(client_socket, client_address)).start()# send_msg(client_socket, client_address)print(fProcess {threading.current_thread()}: {threading.active_count()} threads)print(fTotal threads: {threading.active_count()})print(新客户端连接地址%s % str(client_address))# 读取客户端发送的数据data client_socket.recv(1024)print(Received data:, data.decode())# 向客户端发送数据message Welcome to my server!client_socket.sendall(message.encode())except Exception as e:print(客户端连接异常错误信息%s % e)finally:# 关闭客户端连接client_socket.close()print(客户端连接已关闭)except Exception as e:print(服务器异常错误信息%s % e)traceback.print_exc()# 关闭服务端 socketserver_socket.close()print({}s后尝试重连服务器....format(RECONNECT_INTERVAL))time.sleep(RECONNECT_INTERVAL)def send_msg(client, addr):try:while 1:time.sleep(1)jsonTemplate {Command: FORWARD_ELEV_INFO,DeviceId: C0002T,ElevId: 1,}msg2Elev json.dumps(jsonTemplate).encode() \n.encode()client.sendto(msg2Elev, addr)print(send msg to client:{}:{}.format(addr, msg2Elev))except Exception as e:print(send_msg:{}.format(e))if __name__ __main__:# 启动服务器start_server()2. 开启一个客户端连接连接成功后调用回调函数
import functools
import json
import socket
import threading
import time
import tracebackclass TestClient(threading.Thread):def __init__(self, connectHost, connectPort, callbackFunc):threading.Thread.__init__(self, nameTestClient)self.host connectHostself.port connectPortself.callbackFunc callbackFuncself.sck socket.socket(socket.AF_INET, socket.SOCK_STREAM)def run(self):self.connect()while True:try:# 从socket中读取数据# data self.sck.recv(1024)# print(data)data self.recv_msg(self.sck)if data is None:time.sleep(1)continueself.callbackFunc(data)except OSError:# An operation was attempted on something that is not a sockettraceback.print_exc()time.sleep(5)# FIXME: if socket is broken, reconnect with the same sck does not work, so create an new one.self.sck socket.socket(socket.AF_INET, socket.SOCK_STREAM)self.connect()except Exception as e:# TODO: if disconnected, connect ittraceback.print_exc()time.sleep(5)self.connect()def recv_msg(self, sock):try:data sock.recv(1024)print(recv data:{}.format(data))return dataexcept Exception as e:print(recv_msg:{}.format(e))sock.close()time.sleep(0.5)def connect(self):while True:try:self.sck.connect((self.host, self.port))print(connected to Service {}:{}.format(self.host, self.port))breakexcept ConnectionRefusedError:print(service refused or not started? Reconnecting to Service in 5s)time.sleep(5)except Exception as e:print(connect error type-{}.format(type(e)))traceback.print_exc()# FIXME: if other exception, not sure to restart action will work.time.sleep(5)def callbackFunc(a, res):print(a)print(callback msg -- , res)if __name__ __main__:connectHost 127.0.0.1connectPort 8000callbackFunc callbackFuncelevClient TestClient(connectHost, connectPort, functools.partial(callbackFunc, hello callback))elevClient.start()上面的程序定义了一个回调函数callbackFunc在socket连接完成后将其作为参数传给TestClient类的构造函数用于处理接收到的消息通过回调方式处理从服务端发送回来的数据。
运行结果
以上就是关于python functools.partial设置回调函数处理异步任务基本使用介绍希望对你有所帮助
