जब asyncio का उपयोग कर, आप कैसे अनुमति नहीं सभी में चल रहे कार्यों घटना पाश

Question

मैं निम्नलिखित कोड है बंद करने से पहले खत्म करने के लिए:

@asyncio.coroutine 
def do_something_periodically(): 
    while True: 
     asyncio.async(my_expensive_operation()) 
     yield from asyncio.sleep(my_interval) 
     if shutdown_flag_is_set: 
      print("Shutting down") 
      break 

मैं पूरा जब तक इस समारोह चलाते हैं। समस्या तब होती है जब शट डाउन सेट होता है - फ़ंक्शन पूरा हो जाता है और कोई लंबित कार्य कभी नहीं चलाया जाता है। (आप इसे एक त्रुटि के रूप में देखते हैं

task: <Task pending coro=<report() running at script.py:33> wait_for=<Future pending cb=[Task._wakeup()]>> 

)। मैं शट डाउन को सही तरीके से कैसे शेड्यूल करूं?

कुछ संदर्भ देने के लिए, मैं एक सिस्टम मॉनिटर लिख रहा हूं जो हर 5 सेकंड में/proc/stat से पढ़ता है, उस अवधि में सीपीयू उपयोग की गणना करता है, और फिर परिणाम को सर्वर पर भेजता है। मैं इन निगरानी नौकरियों को शेड्यूल करना चाहता हूं जब तक कि मैं सिगरेट प्राप्त नहीं करता, जब मैं शेड्यूलिंग रोकता हूं, सभी मौजूदा नौकरियों को समाप्त करने की प्रतीक्षा करता हूं, और शानदार तरीके से बाहर निकलता हूं।

Answer 1

आप अधूरे कार्यों को पुनर्प्राप्त कर सकते हैं और लूप को फिर से समाप्त कर सकते हैं, फिर लूप बंद करें या अपने प्रोग्राम से बाहर निकलें।

pending = asyncio.Task.all_tasks() 
loop.run_until_complete(asyncio.gather(*pending)) 

• लंबित लंबित कार्यों की एक सूची है।
• asyncio.gather() एक साथ कई कार्यों पर इंतजार करने की अनुमति देता है। में

  @asyncio.coroutine 
  def do_something_periodically(): 
      while True: 
       asyncio.async(my_expensive_operation()) 
       yield from asyncio.sleep(my_interval) 
       if shutdown_flag_is_set: 
        print("Shutting down") 
        break 
  
      yield from asyncio.gather(*asyncio.Task.all_tasks()) 
  

  इसके अलावा,:

आप सभी कार्य सुनिश्चित करना चाहते हैं एक coroutine (हो सकता है आप एक "मुख्य" coroutine हैं) तो आप इसे इस तरह, कर सकते हैं, उदाहरण के लिए अंदर पूरा कर रहे हैं

@asyncio.coroutine 
def do_something_periodically(): 
    tasks = [] 
    while True: 
     tasks.append(asyncio.async(my_expensive_operation())) 
     yield from asyncio.sleep(my_interval) 
     if shutdown_flag_is_set: 
      print("Shutting down") 
      break 

    yield from asyncio.gather(*tasks)