अजगर Asyncio कार्य बिना इकट्ठा चल रहा है ()

मैं यह क्रिस्टियन गार्सिया द्वारा ब्लॉग पोस्ट, और मैं एक बहुत ही दिलचस्प परिणाम में भाग गया।

यहां दो स्क्रिप्ट हैं जिनका मैंने उपयोग किया है। मैंने एक वास्तविक नेटवर्क अनुरोध को एक यादृच्छिक नींद कॉल के साथ बदल दिया

#task_pool.py
import asyncio

class TaskPool(object):

    def __init__(self, workers):
        self._semaphore = asyncio.Semaphore(workers)
        self._tasks = set()

    async def put(self, coro):
        await self._semaphore.acquire()
        task = asyncio.create_task(coro)
        self._tasks.add(task)
        task.add_done_callback(self._on_task_done)

    def _on_task_done(self, task):
        self._tasks.remove(task)
        self._semaphore.release()

    async def join(self):
        await asyncio.gather(*self._tasks)

    async def __aenter__(self):
        return self

    def __aexit__(self, exc_type, exc, tb):
        print("aexit triggered")
        return self.join()

और

# main.py
import asyncio
import sys
from task_pool import TaskPool
import random
limit = 3

async def fetch(i):
    timereq = random.randrange(5)
    print("request: {} start, delay: {}".format(i, timereq))
    await asyncio.sleep(timereq)
    print("request: {} end".format(i))
    return (timereq,i)

async def _main(total_requests):
    async with TaskPool(limit) as tasks:
        for i in range(total_requests):
            await tasks.put(fetch(i))

loop = asyncio.get_event_loop()
loop.run_until_complete(_main(int(sys.argv[1])))

कमांड main.py 10 अजगर 3.7.1 पर निम्नलिखित परिणाम देता है।

request: 0 start, delay: 3
request: 1 start, delay: 3
request: 2 start, delay: 3
request: 0 end
request: 1 end
request: 2 end
request: 3 start, delay: 4
request: 4 start, delay: 1
request: 5 start, delay: 0
request: 5 end
request: 6 start, delay: 1
request: 4 end
request: 6 end
request: 7 start, delay: 1
request: 8 start, delay: 4
request: 7 end
aexit triggered
request: 9 start, delay: 1
request: 9 end
request: 3 end
request: 8 end

इस परिणाम के आधार पर मेरे कुछ प्रश्न हैं।

1. जब तक संदर्भ प्रबंधक बाहर नहीं निकलता और __aexit__ को ट्रिगर नहीं करता, तब तक मुझे कार्यों के चलने की उम्मीद नहीं थी, क्योंकि asyncio.gather के लिए यही एकमात्र ट्रिगर है। हालाँकि प्रिंट स्टेटमेंट दृढ़ता से सुझाव देते हैं कि fetch कार्य aexit से पहले भी हो रहे हैं। क्या हो रहा है, बिल्कुल? क्या कार्य चल रहे हैं? यदि हां, तो उन्हें क्या शुरू किया?
2. (१) से संबंधित। सभी नौकरियों के वापस आने से पहले संदर्भ प्रबंधक बाहर क्यों निकल रहा है?
3. fetch जॉब को टपल लौटाना चाहिए। मैं इस मूल्य तक कैसे पहुंच सकता हूं? वेब-आधारित एप्लिकेशन के लिए, मुझे लगता है कि डेवलपर वेबसाइट द्वारा लौटाए गए डेटा पर संचालन करना चाहता है।

कोई भी मदद बहुत ही सराहनीय होगी!