एक async webservice विधि

Question

बनाना मैंने एसिंक विधियों को पढ़ने की कोशिश की है और अब मैं अपना स्वयं का एसिंक विधि बनाने की कोशिश कर रहा हूं। विधि एक webservice कॉल है जो त्रुटि लॉग की एक सूची देता है। मुझे यकीन नहीं है कि मैं सही ढंग से समझ गया हूं इसलिए मैंने सोचा कि मैं यह देखने के लिए अपना कोड साझा करूंगा कि मुझे कुछ अलग करना चाहिए या नहीं।

मैं चाहता हूं कि कोड करने के लिए कोड GetAllErrorLogs() पर कॉल करके त्रुटि लॉग की सूची लौटाएं, यह एक सिंक्रनाइज़ विधि है। चूंकि सभी त्रुटि लॉग लाने में एक सेकंड लग सकता है, इसलिए मैं GetAllErrorLogs() विधि कहने के बाद अन्य सामान करने का अवसर प्राप्त करना चाहता हूं। कोड यहाँ है।

[WebMethod] 
public async Task<List<ErrorLog>> GetAllErrorLogs() 
{ 
    List<ErrorLog> errorLogs = new List<ErrorLog>(); 

    await System.Threading.Tasks.Task.Run(() => { 
     errorLogs = ErrorLogRepository.GetAllErrorLogs(); 
    }); 


    if (errorLogs == null) 
     return new List<ErrorLog>(); 

    return errorLogs; 
} 

धन्यवाद!

Answer 1

मैंने हाल ही में ThatConference पर async on the server side पर एक वार्ता दी, और मैं स्लाइड्स में इस समस्या को संबोधित करता हूं।

सर्वर की तरफ, आप Task.Run और अन्य संरचनाओं के उपयोग से बचना चाहते हैं जो थ्रेड पूल में कतार का काम करते हैं। जितना संभव हो, अनुरोधों को संभालने के लिए थ्रेड पूल थ्रेड उपलब्ध रखें।

तो, आदर्श रूप से आपके भंडार में एसिंक्रोनस विधि GetAllErrorLogsAsync होगी, जो स्वयं ही असीमित होगी। यदि GetAllErrorLogs असीमित नहीं हो सकता है, तो आप इसे सीधे कॉल भी कर सकते हैं (await Task.Run को हटाएं)।

चूंकि सभी त्रुटि लॉग लाने के लिए एक सेकंड लग सकता है, इसलिए मैं GetAllErrorLogs() विधि को कॉल करने के बाद अन्य सामान करने का अवसर प्राप्त करना चाहता हूं।

आप एक GetAllErrorLogsAsync उपलब्ध है, तो यह आसानी से Task.WhenAll का उपयोग किया जा सकता है। हालांकि, अगर GetAllErrorLogs तुल्यकालिक है, तो आप केवल अपने अनुरोध में समानांतर काम करके ऐसा कर सकते हैं (उदा।, Task.Run पर कई कॉल Task.WhenAll के बाद)।

सर्वर पर समानांतर कोड को बहुत ही भयावहता के साथ संपर्क किया जाना चाहिए। यह केवल परिदृश्यों के बहुत सीमित सेट में स्वीकार्य है। सर्वर पक्ष पर async का पूरा बिंदु कम प्रति अनुरोध धागे का उपयोग करना है, और जब आप समांतरता शुरू करते हैं, तो आप विपरीत कर रहे हैं: एकाधिक प्रति अनुरोध धागे। यह केवल तभी उपयुक्त है जब आप जानते हैं कि आपका उपयोगकर्ता आधार बहुत छोटा है; अन्यथा, आप अपने सर्वर स्केलेबिलिटी को मार देंगे।

Answer 2

मैं कैसे प्राप्त कि

http://www.codeproject.com/Articles/600926/Asynchronous-web-services-call-in-ASP-NET

Answer 3

** यह संभावित रूप से गलत है, टिप्पणी या spinoff सवाल HttpContext.Current after an await

तो ErrorLogRepository.GetAllErrorLogs() पर पढ़ने के लिए है नहीं थ्रेड के बारे में इस महान codeproject विस्तृत लेख पाया -साफ, यह अजीब कीड़े और संभावित रूप से अपवाद का कारण बन जाएगा। सुनिश्चित करें कि आपका कोड एसिंक तरीकों पर स्विच करने से पहले बहु-थ्रेडेड ऑपरेशन के लिए तैयार है, यह स्पष्ट रूप से बहुत ही छोटी सलाह है लेकिन अक्सर अनदेखा किया जाता है। उदाहरण के लिए, यदि आप अपनी विधियों में HttpContext.Current का संदर्भ देते हैं, तो आपका कोड एसिंक विधि में मर जाएगा, और कभी-कभी await के बाद भी। कारण यह है कि एसिंक ब्लॉक के भीतर कोड संभावित रूप से एक अलग थ्रेड पर चलाया जाएगा, जिसकी HttpContext.Current थ्रेड-स्टेटिक प्रॉपर्टी तक पहुंच नहीं होगी, और await दो तरीकों से संकलित हो जाएगी। await से पहले सभी कोड एक थ्रेड पर चलाए जाते हैं, और फिर निरंतरता के रूप में एक प्रतीक्षा कीवर्ड के बाद कोड को कॉल करते हैं, लेकिन संभावित रूप से अभी तक एक और धागा पर। तो कभी-कभी आपका कोड एसिंक ब्लॉक में भी काम करेगा, केवल एसिंक के "बाहर" होने के बाद अप्रत्याशित रूप से चकित हो जाएगा, जो आपको लगता है कि आपके कोड का एक तुल्यकालिक हिस्सा है (लेकिन हकीकत में await कीवर्ड के बाद सबकुछ पहले ही गारंटी नहीं है मूल धागा होने के लिए)।

Answer 4

यहाँ हैंडलिंग Async अपवाद भी बहुत बहुत महत्वपूर्ण .. हालांकि यह एक खिड़कियों सांत्वना अनुप्रयोग के लिए है, एक ही सिद्धांतों को लागू करना चाहिए कुछ उत्पादन कोड है ...

using System.Web.Http; 
using AysncTask = System.Threading.Tasks.Task; 

public class myController : ApiControllerBase 
{ 
     [HttpPut] 
     [Route("api/cleardata/{id}/{requestId}/")] 
     public async AysncTask ClearData(Guid id, Guid requestId) 
     { 
      try 
      { 
       await AysncTask.Run(() => DoClearData(id, requestId)); 
      } 
      catch (Exception ex) 
      { 
       throw new Exception("Exception in myController.ClearData", ex); 
      } 
     } 
} 

Answer 5

।

स्रोत: https://blogs.msdn.microsoft.com/ptorr/2014/12/10/async-exceptions-in-c/

using System; 
    using System.Runtime.CompilerServices; 
    using System.Threading; 
    using System.Threading.Tasks; 

    namespace AsyncAndExceptions 
    { 
class Program 
{ 
    static void Main(string[] args) 
    { 
    AppDomain.CurrentDomain.UnhandledException += (s, e) => Log("*** Crash! ***", "UnhandledException"); 
    TaskScheduler.UnobservedTaskException += (s, e) => Log("*** Crash! ***", "UnobservedTaskException"); 

    RunTests(); 

    // Let async tasks complete... 
    Thread.Sleep(500); 
    GC.Collect(3, GCCollectionMode.Forced, true); 
    } 

    private static async Task RunTests() 
    { 
    try 
    { 
     // crash 
     // _1_VoidNoWait(); 

     // crash 
     // _2_AsyncVoidAwait(); 

     // OK 
     // _3_AsyncVoidAwaitWithTry(); 

     // crash - no await 
     // _4_TaskNoWait(); 

     // crash - no await 
     // _5_TaskAwait(); 

     // OK 
     // await _4_TaskNoWait(); 

     // OK 
     // await _5_TaskAwait(); 
    } 
    catch (Exception ex) { Log("Exception handled OK"); } 

    // crash - no try 
    // await _4_TaskNoWait(); 

    // crash - no try 
    // await _5_TaskAwait(); 
    } 

    // Unsafe 
    static void _1_VoidNoWait() 
    { 
    ThrowAsync(); 
    } 

    // Unsafe 
    static async void _2_AsyncVoidAwait() 
    { 
    await ThrowAsync(); 
    } 

    // Safe 
    static async void _3_AsyncVoidAwaitWithTry() 
    { 
    try { await ThrowAsync(); } 
    catch (Exception ex) { Log("Exception handled OK"); } 
    } 

    // Safe only if caller uses await (or Result) inside a try 
    static Task _4_TaskNoWait() 
    { 
    return ThrowAsync(); 
    } 

    // Safe only if caller uses await (or Result) inside a try 
    static async Task _5_TaskAwait() 
    { 
    await ThrowAsync(); 
    } 

    // Helper that sets an exception asnychronously 
    static Task ThrowAsync() 
    { 
    TaskCompletionSource tcs = new TaskCompletionSource(); 
    ThreadPool.QueueUserWorkItem(_ => tcs.SetException(new Exception("ThrowAsync"))); 
    return tcs.Task; 
    } 
    internal static void Log(string message, [CallerMemberName] string caller = "") 
    { 
    Console.WriteLine("{0}: {1}", caller, message); 
    } 
} 

}