在計算機(jī)程序設(shè)計中,回調(diào)函數(shù),或簡稱回調(diào)(Callback),是指通過函數(shù)參數(shù)傳遞到其它代碼的,某一塊可執(zhí)行代碼的引用。這一設(shè)計允許了底層代碼調(diào)用在高層定義的子程序:
創(chuàng)新互聯(lián)公司于2013年創(chuàng)立,先為紹興等服務(wù)建站,紹興等地企業(yè),進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為紹興企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問題。
例如:
def?my_callback(input):
print?"function?my_callback?was?called?with?%s?input"?%?(input,)
def?caller(input,?func):
func(input)
for?i?in?range(5):
caller(i,?my_callback)
執(zhí)行結(jié)果是:
function?my_callback?was?called?with?0?input
function?my_callback?was?called?with?1?input
function?my_callback?was?called?with?2?input
function?my_callback?was?called?with?3?input
function?my_callback?was?called?with?4?input
為了管理協(xié)程和I/O的回調(diào)函數(shù),asyncio庫的事件循環(huán)也能基于定時的方式調(diào)用普通的函數(shù),使用call_soon()函數(shù),例子如下:
import?asyncio??
import?functools??
def?callback(arg,?*,?kwarg='default'):??
print('callback?invoked?with?{}?and?{}'.format(arg,?kwarg))??
async?def?main(loop):??
print('registering?callbacks')??
loop.call_soon(callback,?1)??
wrapped?=?functools.partial(callback,?kwarg='not?default')??
loop.call_soon(wrapped,?2)??
await?asyncio.sleep(0.1)??
event_loop?=?asyncio.get_event_loop()??
try:??
print('entering?event?loop')??
event_loop.run_until_complete(main(event_loop))??
finally:??
print('closing?event?loop')??
event_loop.close()
結(jié)果輸出如下:
entering event loop
registering callbacks
callback invoked with 1 and default
callback invoked with 2 and not default
closing event loop
1. 我忘了ctypes的操作方法是:
下面是從復(fù)制
因此,我們的回調(diào)函數(shù)接收整型指針,并且必須返回一個整數(shù)。首先,我們創(chuàng)建了回調(diào)函數(shù)的類型:
CMPFUNC = CFUNCTYPE(c_int, POINTER(c_int), POINTER(c_int))
對于優(yōu)先個回調(diào)函數(shù)中,我們簡單地打印出我們得到,并返回0(;-):
def py_cmp_func(a, b):
print "py_cmp_func", a, b
return 0
創(chuàng)建C可調(diào)用的回調(diào)函數(shù):
cmp_func = CMPFUNC(py_cmp_func)
協(xié)程函數(shù):async def?函數(shù)名。3.5+
協(xié)程對象:執(zhí)行協(xié)程函數(shù)()得到的協(xié)程對象。
3.5之后的寫法:
3.7之后的寫法:更簡便
await后面?跟?可等待的對象。(協(xié)程對象,F(xiàn)uture,Task對象?約等于IO等待)
await實例2:串行執(zhí)行。 一個協(xié)程函數(shù)里面可以支持多個await ,雖然會串行,但是如果有其他協(xié)程函數(shù),任務(wù)列表也在執(zhí)行,依然會切換。只是案例中的main對應(yīng)執(zhí)行的others1和others2串行 。 await會等待對象的值得到之后才繼續(xù)往下走。
python回調(diào)函數(shù)的使用方法
在計算機(jī)程序設(shè)計中,回調(diào)函數(shù),或簡稱回調(diào)(Callback),是指通過函數(shù)參數(shù)傳遞到其它代碼的,某一塊可執(zhí)行代碼的引用。這一設(shè)計允許了底層代碼調(diào)用在高層定義的子程序
有兩種類型的回調(diào)函數(shù):
那么,在python中如何實現(xiàn)回調(diào)函數(shù)呢,看代碼:
代碼如下:
def my_callback(input):
print "function my_callback was called with %s input" % (input,)
def caller(input, func):
func(input)
for i in range(5):
caller(i, my_callback)
在使用ros::spin()的情況下,一般來說在初始化時已經(jīng)設(shè)置好所有消息的回調(diào),并且不需要其他背景程序運行。這樣以來,每次消息到達(dá)時會執(zhí)行用戶的回調(diào)函數(shù)進(jìn)行操作,相當(dāng)于程序是消息事件驅(qū)動的;而在使用ros::spinOnce()的情況下,一般來說僅僅使用回調(diào)不足以完成任務(wù),還需要其他輔助程序的執(zhí)行:比如定時任務(wù)、數(shù)據(jù)處理、用戶界面等。
關(guān)于消息接收回調(diào)機(jī)制在ROS官網(wǎng)上略有說明 (callbacks and spinning)。總體來說其原理是這樣的:除了用戶的主程序以外,ROS的socket連接控制進(jìn)程會在后臺接收訂閱的消息,所有接收到的消息并不是立即處理,而是等到spin()或者spinOnce()執(zhí)行時才集中處理。所以為了保證消息可以正常接收,需要尤其注意spinOnce()函數(shù)的使用 (對于spin()來說則不涉及太多的人為因素)。
I. 對于速度較快的消息,需要注意合理控制消息隊列及spinOnce()的時間。例如,如果消息到達(dá)的頻率是100Hz,而spinOnce()的執(zhí)行頻率是10Hz,那么就要至少保證消息隊列中預(yù)留的大小大于10。
II. 如果對于用戶自己的周期性任務(wù),最好和spinOnce()并列調(diào)用。即使該任務(wù)是周期性的對于數(shù)據(jù)進(jìn)行處理,例如對接收到的IMU數(shù)據(jù)進(jìn)行Kalman濾波,也不建議直接放在回調(diào)函數(shù)中:因為存在通信接收的不確定性,不能保證該回調(diào)執(zhí)行在時間上的穩(wěn)定性。
// 示例代碼
ros::Rate r(100);
while (ros::ok())
{
libusb_handle_events_timeout(...); // Handle USB events
ros::spinOnce(); // Handle ROS events
r.sleep();
}
III. 最后說明一下將ROS集成到其他程序架構(gòu)時的情況。有些圖形處理程序會將main()包裹起來,此時就需要找到一個合理的位置調(diào)用ros::spinOnce()。比如對于OpenGL來說,其中有一個方法就是采用設(shè)置定時器定時調(diào)用的方法:
// 示例代碼
void timerCb(int value) {
ros::spinOnce();
}
glutTimerFunc(10, timerCb, 0);
glutMainLoop(); // Never returns
網(wǎng)頁標(biāo)題:python協(xié)程回調(diào)函數(shù) python中的回調(diào)函數(shù)
網(wǎng)站地址:http://m.newbst.com/article46/hjpehg.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供建站公司、企業(yè)建站、定制網(wǎng)站、搜索引擎優(yōu)化、營銷型網(wǎng)站建設(shè)、品牌網(wǎng)站建設(shè)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)