작업은 동 기적으로

Question

나는 사용자가 EF를 통해 로그인 할 때 WebUser 객체를로드하는 웹 포털에서 일하고 있어요 문제점

실행 컨트롤러 액션의 시작. WebUser은 사소한 개체 그래프가 있으며 EF를 통해로드하는 데 2-3 초가 걸릴 수 있습니다 (로드 시간을 최적화하는 것이 별도의 문제 임).

인식 성능을 향상시키기 위해 사용자가 시스템에 별도의 스레드에 로그온하자마자 WebUser을로드하려고합니다. 그러나 현재의 시도는 내가 이해할 수없는 이유로 동 기적으로 실행됩니다.

강령

static private ConcurrentDictionary<string, WebUser> userCache = 
     new ConcurrentDictionary<string, WebUser>(); 

static public void CacheProfile(string userName) 
{ 
    if (!userCache.ContainsKey(userName)) 
    { 
     logger.Debug("In CacheProfile() and there is no profile in cache"); 
     Task bg = GetProfileAsync(userName); 
     logger.Debug("Done CacheProfile()"); 
    } 
} 

static public async Task<WebUser> GetProfileAsync(string userName) 
{ 
    logger.Debug("GetProfileAsync for " + userName); 

    await currentlyLoading.NotInSet(userName); // See NOTE 1 below 

    if (userCache.ContainsKey(userName)) 
    { 
     logger.Debug("GetProfileAsync from memory cache for " + userName); 
     return userCache[userName]; 
    } 
    else 
    { 
     currentlyLoading.Add(userName); 

     logger.Debug("GetProfileAsync from DB for " + userName); 

     using (MembershipContext ctx = new MembershipContext()) 
     { 
      ctx.Configuration.LazyLoadingEnabled = false; 
      ctx.Configuration.ProxyCreationEnabled = false; 
      ctx.Configuration.AutoDetectChangesEnabled = false; 

      var wu = GetProfileForUpdate_ExpensiveMethod(ctx, userName); 
      userCache[userName] = wu; 
      currentlyLoading.Remove(userName); 

      return wu; 
     } 
    } 

} 

주 1 : currentlyLoading은 ConcurrentWaitUntil<T>의 정적 인스턴스입니다. 첫 번째 요청이 여전히 데이터베이스에서로드되는 경우 의도 된 사용자의 프로필에 대한 두 번째 요청이 차단되도록하는 것이 그 의도입니다. 아마도 이것을 성취하는 더 좋은 방법이 있을까요? 코드 :

public class ConcurrentWaitUntil<T> 
{ 
    private HashSet<T> set = new HashSet<T>(); 
    private Dictionary<T, TaskCompletionSource<bool>> completions = new Dictionary<T, TaskCompletionSource<bool>>(); 

    private object locker = new object(); 

    public async Task NotInSet(T item) 
    { 
     TaskCompletionSource<bool> completion; 

     lock (locker) 
     { 
      if (!set.Contains(item)) return; 

      completion = new TaskCompletionSource<bool>(); 
      completions.Add(item, completion); 
     } 

     await completion.Task; 
    } 

    public void Add(T item) 
    { 
     lock (locker) 
     { 
      set.Add(item); 
     } 
    } 

    public void Remove(T item) 
    { 
     lock (locker) 
     { 
      set.Remove(item); 

      TaskCompletionSource<bool> completion; 
      bool found = completions.TryGetValue(item, out completion); 

      if (found) 
      { 
       completions.Remove(item); 

       completion.SetResult(true); // This will allow NotInSet() to complete 
      } 
     } 
    } 
} 

이

왜 CacheProfile()이 GetProfileAsync() 때까지 기다려야 할 것 같다 않는 질문이

을 완료?

참고 : ConcurrentDictionary은 확장 성이 뛰어나며 ASP.Net의 캐시를 사용해야한다는 것을 알고 있습니다.

Answer 1

왜 CacheProfile()은 GetProfileAsync()가 완료 될 때까지 기다리는 것처럼 보입니까? 당신의 GetProfileAsync 먼저 몇 가지 비동기 작업을 수행 한 후동기 데이터베이스 호출 및 을하고 같은

는 소리가 난다.

EF를 사용하고 있으므로 EF6으로 업그레이드하고 asynchronous queries을 사용하여이 문제를 해결할 수 있습니다.

또는 Task.Run으로 설정하면 효과적 일 수 있지만 확장성에 해를 끼치기 때문에 서버 측에서 권장하지 않습니다.보조 노트에

, 나는 그들이 작업 대신 결과의를 캐시하도록 메모리 비동기 캐시를 구성하는 것을 선호하므로이 같은 : 초기 로그인에 그런

static private ConcurrentDictionary<string, Task<WebUser>> userCache = new ConcurrentDictionary<string, Task<WebUser>>(); 

static public Task<WebUser> GetProfileAsync(string userName) 
{ 
    return userCache.GetOrAdd(userName, _ => 
    { 
    logger.Debug("In GetProfileAsync() and there is no profile in cache"); 
    return LoadProfileAsync(userName); 
    }); 
} 

static private async Task<WebUser> LoadProfileAsync(string userName) 
{ 
    // Load it from DB using EF6 async queries. 
    // Don't block other callers. 

    logger.Debug("Loading from DB complete"); 
} 

, 당신 GetProfileAsync을 호출하고 그 결과를 무시하면됩니다.

Answer 2

CacheProfile 메소드도 비동기 적이어야합니다.

static void ReadAndCache() 
{ 
    // retrieve and place in cache 
} 

static public void GetProfileAsync(string userName) 
{ 
    Task.Run(() => ReadAndCache()); 
} 

Answer 3

을 당신이 behavior.Please 다음

보고 원하는 얻을 것이다 await를 사용하여 생각 : 당신은 그냥 불을 원하고 이것을 사용 잊어 버린 경우가 GetProfileAsync

발생할 때까지 그렇지 않으면 끝나지 않을 것

static public void CacheProfile(string userName) 
{ 
    if (!userCache.ContainsKey(userName)) 
    { 
     logger.Debug("In CacheProfile() and there is no profile in cache"); 
     Task bg = GetProfileAsync(userName); 
     logger.Debug("Done CacheProfile()"); 
    } 
} 

static public async Task<WebUser> GetProfileAsync(string userName) 
{ 
    //load you data here. 
    // will create a new thread and start task and return to the calling method. 
    return await Task.Run(() => { 
       //your code which fetches data goes here 
       //which returns a "WebUser" object 
      }); 
    logger.Debug("Loading from DB complete"); 
}