Tworzenie metody asynchronicznej usługi sieciowej

Question

Próbowałem przeczytać na temat metod asynchronicznych i teraz próbuję utworzyć własną metodę asynchroniczną. Metoda jest wywołaniem usługi WWW, które zwraca listę dzienników błędów. Nie jestem pewien, czy zrozumiałem poprawnie, więc pomyślałem, że podzielę się moim kodem, aby sprawdzić, czy powinienem zrobić coś innego.

Wszystko, co chcę zrobić, to zwrócić listę błędów, wywołując metodę GetAllErrorLogs(), która jest metodą zsynchronizowaną. Ponieważ może zająć sekundę, aby pobrać wszystkie dzienniki błędów, chcę mieć możliwość zrobienia innych rzeczy, gdy zadzwoniłem do metody GetAllErrorLogs(). Oto kod.

[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; 
} 

Dzięki!

Answer 1

Niedawno wygłosiłem wykład pod adresem ThatConference pod numerem async on the server side i rozwiązuję ten problem na slajdach.

Po stronie serwera należy unikać używania Task.Run i innych konstrukcji, które działają w kolejce do puli wątków. O ile to możliwe, pozostaw wątki puli wątków dostępne do obsługi żądań.

Idealnie więc twoje repozytorium miałoby asynchroniczną metodę GetAllErrorLogsAsync, która sama byłaby asynchroniczna. Jeśli GetAllErrorLogs nie może być asynchroniczny, możesz równie dobrze wywołać to bezpośrednio (usuwając await Task.Run).

Ponieważ pobranie wszystkich dzienników błędów może zająć sekundę, chcę mieć możliwość zrobienia innych rzeczy po wywołaniu metody GetAllErrorLogs().

Jeśli masz dostępne GetAllErrorLogsAsync, można to łatwo zrobić, używając Task.WhenAll. Jeśli jednak GetAllErrorLogs jest synchroniczna, możesz to zrobić tylko wykonując pracę równoległą w swoim żądaniu (np. Wiele połączeń z numerem Task.Run, a następnie Task.WhenAll).

Do równoległego kodu na serwerze należy podchodzić z wielkim niepokojem. Jest to dopuszczalne tylko w bardzo ograniczonym zestawie scenariuszy. Cały punkt async po stronie serwera polega na użyciu od mniejszej liczby wątków na żądanie, a gdy rozpoczniesz pracę równoległą, robisz odwrotnie: wiele wątków na żądanie. Jest to właściwe tylko wtedy, gdy wiesz, że twoja baza użytkowników jest bardzo mała; w przeciwnym razie zabijesz skalowalność serwera.

Answer 2

znalazłem ten wielki codeproject szczegółowy artykuł o tym, jak osiągnąć

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

Answer 3

** Jest to potencjalnie źle, czytać komentarze lub Spinoff pytanie na HttpContext.Current after an await

If ErrorLogRepository.GetAllErrorLogs() nie jest gwint -safe, spowoduje to dziwne błędy i potencjalnie wyjątek. Upewnij się, że Twój kod jest gotowy do pracy wielowątkowej przed przełączeniem na metody asynchroniczne, jest to oczywiście bardzo banalna porada, ale często pomijana. Na przykład, jeśli odwołasz się do HttpContext.Current w swoich metodach, twój kod zginie w metodzie asynchronicznej, a czasami nawet PO await. Powodem jest to, że kod w bloku asynchronicznym może być uruchamiany w osobnym wątku, który nie będzie miał dostępu do tej samej właściwości statycznej wątku, a await zostanie skompilowany na dwie metody. Cały kod przed numerem await jest uruchamiany w jednym wątku, a następnie wywołuje kod po oczekiwaniu na słowo kluczowe jako kontynuację, ale potencjalnie w jeszcze innym wątku. Tak więc czasami twój kod będzie działał nawet w bloku asynchronicznym, tylko po to, aby dusić się niespodziewanie po tym, jak zostanie "wyprowadzony" z asynchronizmu z powrotem do tego, co uważasz za synchroniczną część twojego kodu (ale w rzeczywistości wszystko po słowie kluczowym await nie jest już gwarantowane być oryginalnym wątkiem).

Answer 4

Oto kod produkcji ...

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

Obsługa wyjątków ASYNC jest również bardzo ważne .. choć jest to dla app konsoli okna, te same zasady powinny mieć zastosowanie.

źródło: 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); 
    } 
} 

}