अजगर asyncio add_done_callback साथ async डीईएफ़

Question

2 कार्यों: पहले एक, def_a, एक अतुल्यकालिक समारोह है और दूसरा एक def_b एक नियमित कार्य है और add_done_callback समारोह के साथ एक कॉलबैक के रूप में def_a के परिणाम के साथ कहा जाता है जो है।

मेरे कोड इस तरह दिखता है:

import asyncio 

def def_b(result): 
    next_number = result.result() 
    # some work on the next_number 
    print(next_number + 1) 

async def def_a(number): 
    await some_async_work(number) 
    return number + 1 

loop = asyncio.get_event_loop() 
task = asyncio.ensure_future(def_a(1)) 
task.add_done_callback(def_b) 
response = loop.run_until_complete(task) 
loop.close() 

और यह पूरी तरह से काम है।

समस्या तब शुरू हुई जब दूसरा फ़ंक्शन, def_b, असीमित हो गया। अब यह इस तरह दिखता है:

async def def_b(result): 
    next_number = result.result() 
    # some asynchronous work on the next_number 
    print(next_number + 1) 

लेकिन अब मैं add_done_callback कार्य करने के लिए यह प्रदान नहीं कर सकते, क्योंकि यह एक नियमित रूप से समारोह में नहीं है।

मेरा प्रश्न है- क्या यह संभव है और def_b फ़ंक्शन पर def_b असीमित है, तो मैं def_b कैसे प्रदान कर सकता हूं?

Answer 1

add_done_callback को "निम्न स्तर" इंटरफ़ेस माना जाता है। जब coroutines के साथ काम करने के लिए, आप chain them कई मायनों, उदाहरण के लिए कर सकते हैं:

import asyncio 


async def my_callback(result): 
    print("my_callback got:", result) 
    return "My return value is ignored" 


async def coro(number): 
    await asyncio.sleep(number) 
    return number + 1 


async def add_success_callback(fut, callback): 
    result = await fut 
    await callback(result) 
    return result 


loop = asyncio.get_event_loop() 
task = asyncio.ensure_future(coro(1)) 
task = add_success_callback(task, my_callback) 
response = loop.run_until_complete(task) 
print("response:", response) 
loop.close() 

मन add_done_callback रखें अभी भी कॉलबैक फोन करेगा, तो अपने भविष्य के लिए एक अपवाद को जन्म देती है (लेकिन बुला result.result() यह बढ़ा देंगे)।