Tạm dừng REST của đồng thời gọi cho đến khi người đầu tiên hoàn thành

Question

Chúng tôi có một phương pháp REST API tương tự như:

List<item> GetItems(int AccountID) 
{ 
    var x = getFromCache(AccountID); 
    if(x==null) 
    { 
     x = getFromDatabase(AccountID); 
     addToCache(AccountID, x); 
    } 
    return x; 
} 

Đây là một phương pháp khá tốn kém với một số DB phức tạp gọi, và chúng tôi có một tình huống phổ biến nơi hàng trăm người dùng với cùng một AccountId sẽ thực hiện cuộc gọi gần như đồng thời (tất cả chúng đều được thông báo bằng một chương trình phát sóng).

Trong phương pháp, chúng tôi lưu vào bộ kết quả trong 10 giây vì kết quả gần thời gian là tốt cho mọi người đưa ra yêu cầu trong cửa sổ đó. Tuy nhiên, vì tất cả chúng đều thực hiện cuộc gọi cùng một lúc (một lần nữa, đối với một AccountID cụ thể), bộ đệm không bao giờ được điền trước, vì vậy mọi người sẽ kết thúc cuộc gọi cơ sở dữ liệu. Vì vậy, câu hỏi của tôi là, trong phương thức, làm thế nào tôi có thể tạm dừng tất cả các yêu cầu đến cho một tài khoản cụ thểId và khiến tất cả chờ kết quả đầu tiên hoàn thành, để phần còn lại của cuộc gọi có thể sử dụng bộ nhớ cache kết quả được đặt?

Tôi đã đọc một chút về Monitor.Pulse và Monitor.Lock nhưng việc triển khai loại khóa cho mỗi loại tài khoản thoát khỏi tôi. Bất kỳ trợ giúp nào sẽ được đánh giá cao.

Answer 1

Bạn phải khóa trên cùng một đối tượng cho các yêu cầu có cùng AccountId nhưng sử dụng đối tượng khác nhau cho từng AccountId riêng lẻ. Dưới đây là ví dụ về cách sử dụng Dictionary để theo dõi đối tượng khóa cho các AccountIds riêng lẻ.

Dictionary<int, Object> Locks = new Dictionary<int, object>(); 

    List<item> GetItems(int AccountID) 
    { 
     //Get different lock object for each AccountId 
     Object LockForAccountId = GetLockObject(AccountID); 

     //block subsequent threads until first thread fills the cache 
     lock (LockForAccountId) 
     { 
      var x = getFromCache(AccountID); 
      if (x == null) 
      { 
       x = getFromDatabase(AccountID); 
       addToCache(AccountID, x); 
      } 
      return x; 
     } 
    } 

    private Object GetLockObject(int AccountID) 
    { 
     Object LockForAccountId; 

     //we must use global lock while accessing dictionary with locks to prevent multiple different lock objects to be created for the same AccountId 
     lock (Locks) 
     { 
      if (!Locks.TryGetValue(AccountID, out LockForAccountId)) 
      { 
       LockForAccountId = new Object(); 
       Locks[AccountID] = LockForAccountId; 
      } 
     } 
     return LockForAccountId; 
    } 

Answer 2

Bạn đã nghĩ đến việc sử dụng Lazy<T> cho điều này?

Hãy thử mã này:

private object _gate = new object(); 
List<item> GetItems(int AccountID) 
{ 
    lock (_gate) 
    { 
     var x = getFromCache(AccountID); 
     if (x == null) 
     { 
      x = new Lazy<List<item>>(() => getFromDatabase(AccountID)); 
      addToCache(AccountID, x); 
     } 
     return x.Value; 
    } 
} 

Bạn sẽ cần phải thay đổi getFromCache & addToCache để có chữ ký sau đây:

Lazy<List<item>> getFromCache(int AccountID) 
void addToCache(int AccountID, Lazy<List<item>> x)