Tạo phương thức dịch vụ web không đồng bộ

Question

Tôi đã cố gắng đọc các phương thức không đồng bộ và hiện đang cố gắng tạo phương thức không đồng bộ của riêng mình. Phương thức là một cuộc gọi webservice trả về một danh sách các bản ghi lỗi. Tôi không chắc rằng tôi đã hiểu chính xác vì vậy tôi nghĩ rằng tôi muốn chia sẻ mã của tôi để xem nếu tôi nên làm bất cứ điều gì khác nhau.

Tất cả những gì tôi muốn làm là trả về danh sách các bản ghi lỗi bằng cách gọi phương thức GetAllErrorLogs(), đó là phương thức được đồng bộ hóa. Vì có thể mất một giây để lấy tất cả các bản ghi lỗi, tôi muốn có cơ hội thực hiện các công cụ khác khi tôi gọi phương thức GetAllErrorLogs(). Đây là mã.

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

Cảm ơn!

Answer 1

Gần đây tôi đã nói chuyện tại ThatConference trên async on the server side và tôi giải quyết vấn đề này trong các trang trình bày.

Ở phía máy chủ, bạn muốn tránh sử dụng Task.Run và các cấu trúc khác xếp hàng hoạt động với nhóm luồng. Càng nhiều càng tốt, giữ các chủ đề của chuỗi chủ đề có sẵn để xử lý các yêu cầu.

Vì vậy, lý tưởng là kho lưu trữ của bạn sẽ có phương thức không đồng bộ GetAllErrorLogsAsync, chính nó sẽ không đồng bộ. Nếu GetAllErrorLogs không thể không đồng bộ, thì bạn cũng có thể gọi trực tiếp ngay (xóa await Task.Run).

Vì có thể mất một giây để tìm nạp tất cả nhật ký lỗi Tôi muốn có cơ hội thực hiện các công cụ khác khi tôi gọi phương thức GetAllErrorLogs().

Nếu bạn có sẵn GetAllErrorLogsAsync thì có thể dễ dàng thực hiện bằng cách sử dụng Task.WhenAll. Tuy nhiên, nếu GetAllErrorLogs đồng bộ, thì bạn chỉ có thể thực hiện việc này bằng cách thực hiện công việc song song trong yêu cầu của mình (ví dụ: nhiều cuộc gọi đến Task.Run theo sau là Task.WhenAll).

Mã song song trên máy chủ phải được tiếp cận với sự lo lắng lớn. Nó chỉ được chấp nhận trong một tập hợp rất hạn chế các kịch bản. Toàn bộ điểm của async ở phía máy chủ là sử dụng ít hơn chủ đề cho mỗi yêu cầu và khi bạn bắt đầu song song, bạn đang làm ngược lại: nhiều chủ đề cho mỗi yêu cầu. Điều này chỉ thích hợp nếu bạn biết cơ sở người dùng của mình rất nhỏ; nếu không, bạn sẽ giết khả năng mở rộng máy chủ của mình.

Answer 2

tôi thấy CodeProject bài viết chi tiết tuyệt vời này về làm thế nào để đạt được điều đó

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

Answer 3

** Đây là khả năng sai, đọc ý kiến ​​hoặc câu hỏi spinoff tại HttpContext.Current after an await

Nếu ErrorLogRepository.GetAllErrorLogs() không phải là thread an toàn, nó sẽ gây ra lỗi lạ và có khả năng ngoại lệ. Đảm bảo mã của bạn đã sẵn sàng cho hoạt động đa luồng trước khi chuyển sang phương thức không đồng bộ, điều này rõ ràng là lời khuyên rất nhỏ nhưng thường bị bỏ qua. Ví dụ: nếu bạn tham chiếu HttpContext.Current trong các phương pháp của mình, mã của bạn sẽ chết theo phương thức không đồng bộ và đôi khi thậm chí SAU là await. Lý do là mã trong khối async sẽ có khả năng chạy trên một chuỗi riêng biệt, mà sẽ không có quyền truy cập vào cùng một thuộc tính luồng tĩnh HttpContext.Current và await được biên dịch thành hai phương thức. Tất cả các mã trước khi một await được chạy trên một sợi, và sau đó gọi mã sau một từ khóa chờ đợi như là một sự tiếp nối, nhưng có khả năng trên một chủ đề khác. Vì vậy, đôi khi mã của bạn thậm chí sẽ hoạt động trong một khối không đồng bộ, chỉ để nghẹt thở bất ngờ sau khi nó được "ra" của async trở lại những gì bạn nghĩ là một phần đồng bộ của mã của bạn (nhưng trong thực tế tất cả mọi thứ sau khi một từ khóa await đã không được bảo đảm làm chủ đề ban đầu).

Answer 4

Dưới đây là một số mã sản xuất ...

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

Xử lý ngoại lệ Async cũng là rất rất quan trọng .. mặc dù đây là một ứng dụng cửa sổ giao diện điều khiển, cùng một nguyên tắc nên áp dụng.

nguồn: 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); 
    } 
} 

}