비동기 프로세스를 호출하는 루프를 리 팩터 처리합니다.

Question

루프를 통과하는 프로세스가 있습니다. 루프가 반복 될 때마다 외부 웹 서비스를 호출 한 다음 객체를 EntityFramework 저장소에 추가합니다. 외부 서비스 호출은 정적 메서드로 래핑됩니다. 일반적으로 루프에는 하나 또는 두 개의 반복 만 있지만 현재 UI에서는 최대 4 개까지 반복 할 수 있습니다. (각 반복은 보험 견적을 나타냄).

비동기 프로세스로 리팩터링하는 것이 이점으로 보입니다. 각 반복이 별도의 스레드에서 발생하도록 모든 스레드를 완료 할 때까지 대기하도록 커늘을 설정하는 방법은 무엇입니까?

public class ProcessRequest 
{ 
    private IUnitOfWork = unitOfWork; 

    public ProcessRequest(IUnitOfWork uow) 
    { 
     unitOfWork = uow; 
    } 

    public void Execute(MyRequestParams p) 
    { 
     foreach (Quote q in p.Quotes) 
     { 
      q.Premium = QuoteService.GetQuote(q); 
      unitOfWork.GetRepository<Quote>().Add(q); 
     } 

     unitOfWork.Commit(); 
    } 
} 

public static class QuoteService 
{ 
    public static decimal GetQuote(Quote quote) 
    { 
     //I've simplified proprietary code to single line that calls an external service 
     return ExternalWebService.GetQuote(quote.Deductible); 
    } 
} 

Answer 1

당신은 다른 두 가지를 요구하고 하나는 각각의 반복이 발생할 경우 별도의 스레드에서 (잠재적으로), 병렬에 루프 을 실행하는 방법입니다; 이는 루프 전체를 비동기 프로세스으로 실행하는 것과 완전히 다릅니다. 즉, 시작하는 스레드가 완료 될 때까지 기다리지 않음을 의미합니다. 첫 번째를 의미한다고 가정합니다. 즉 루프의 반복을 병렬 처리하려고하지만 모든 작업이 완료 될 때까지 계속 차단하고 싶다고 가정합니다.

public void Execute(MyRequestParams p) 
{ 
    Parallel.ForEach(p.Quotes, q => { 
    q.Premium = QuoteService.GetQuote(q); 
    unitOfWork.GetRepository<Quote>().Add(q); 
    }); 

    unitOfWork.Commit(); 
} 

아니면 뭔가 같은 :

public void Execute(MyRequestParams p) 
{ 
    Parallel.ForEach(p.Quotes, q => { 
    q.Premium = QuoteService.GetQuote(q); 
    }); 

    unitOfWork.GetRepository<Quote>().AddAll(p.Quotes); 
    unitOfWork.Commit(); 
} 

이것은 따라이 실행되는 상황에 대해 아무것도 모른 채

, 하나의 간단한 방법은 병렬 확장, 특히 병렬의 Foreach를 사용하는 것 당신이 다루는 스레드 안전에 크게 의존합니다.

Answer 2

대부분의 작업이 I/O 인 경우 서비스/DB가 응답 할 때까지 기다리는 시간을 대부분 낭비하므로 새 스레드를 돌리는 데 대한 확신이 없습니다.

나는 비동기 방식으로 이동하려고 할 것 :이 방법으로

public async Task Execute(MyRequestParams p) 
{ 
    foreach (var quote in p.Quotes) 
    { 
    //Of course, you'll need an async endpoint. 
    var q.Premium = await QuoteService.GetQuoteAsync(q); 
    } 

    unitOfWork.GetRepository<Quote>().AddAll(p.Quotes); 
    await unitOfWork.SaveChangesAsync(); 
} 

, 새로운 스레드를 회전하고 대부분의 시간을 유휴시키는 오버 헤드를 저장합니다. 희망적이라면 당연히 웹 서비스의 비동기 끝점에 대한 액세스 권한을 갖고 Entity Framework v6을 사용해야합니다.