일련의 메소드를 병렬로 실행하십시오.

Question

REST API에 연결하고 여러 오브젝트를 가져 오기 위해 여러 엔드 포인트를 호출 중입니다.

RestService<Agent> agentService = new RestService<Agent>(auth, new AgentApi()); 
RestService<Ticket> ticketService = new RestService<Ticket>(auth, new TicketApi()); 
RestService<Company> companyService = new RestService<Company>(auth, new CompanyApi()); 
RestService<Contact> contactService = new RestService<Contact>(auth, new ContactApi()); 

각 RestService<T>를 들어 내가 다음 결과 나머지 API를 호출하여 얻을 수 GetAll() 전화 : 장면 GetAll() 뒤에

RestResult<Agent> agentResults = agentService.GetAll(); 
RestResult<Company> companyResults = companyService.GetAll(); 
RestResult<Contact> contactResults = contactService.GetAll(); 
RestResult<Ticket> ticketResults = ticketService.GetAll(); 

숫자를 만들어 내가 다운로드 할 각 유형에 대한 RestService<T> 작성 HttpWebRequest 재발행

그래서 저는 어떻게 든 4 GetAll()을 병렬로 호출해야한다고 말합니다. 이론적으로 나는 하나가 아닌 REST API에 여러 요청을 할 수 있습니다.

RestResult<Agent> agentResults; 
RestResult<Company> companyResults; 
RestResult<Contact> contactResults; 
RestResult<Ticket> ticketResults; 

Parallel.Invoke(
    () => agentResults = agentService.GetAll(), 
    () => companyResults = companyService.GetAll(), 
    () => contactResults = contactService.GetAll(), 
    () => ticketResults = ticketService.GetAll() 
); 

그러나 변수가 초기화되지 않습니다 것 같습니다 : 내가 가진

하나의 아이디어였다.

이 방법에 대한 제안 사항은 무엇입니까?

Answer 1

당신의 컴파일러는 컴파일러가 의미를 Parallel.Invoke()의을 이해하지 못하기 때문에 변수가 초기화되지 않습니다 있음을 경고합니다.

컴파일러가 알고있는 유일한 점은 그 함수에 람다를 전달한다는 것입니다. 그러나 그들이 처형 될 때 추측 할 수는 없습니다. 컴파일러는 Action이 완료 될 때 Parallel.Invoke() 만 반환한다는 것을 모릅니다. 그리고 그것은 특히 당신의 람다가 변수를 초기화하고 있다는 것을 모릅니다.

따라서 컴파일러의 관점에서 보면 Parallel.Invoke() 이후에도 변수에 값을 지정하지 않았습니다.

RestResult<Agent> agentResults = null; 
RestResult<Company> companyResults = null; 
RestResult<Contact> contactResults = null; 
RestResult<Ticket> ticketResults = null; 

Parallel.Invoke(
    () => agentResults = agentService.GetAll(Epoch), 
    () => companyResults = companyService.GetAll(Epoch), 
    () => contactResults = contactService.GetAll(Epoch), 
    () => ticketResults = ticketService.GetAll(Epoch) 
); 

Answer 2

이 질문을 한 번 보시고 귀하와 같은 문제가있는 것 같습니다. Parallel.Invoke는 비동기 작업을 기다리지 않는 것 같습니다. 대신 모든 작업이 완료 될 때까지 기다려야 Task.WhenAll를 사용 Parallel.Invoke does not wait for async methods to complete

RestResult<Agent> agentResults; 
RestResult<Company> companyResults; 
RestResult<Contact> contactResults; 
RestResult<Ticket> ticketResults; 

var t1 = Task.Run(() => agentResults = agentService.GetAll(Epoch)) 
var t2 = Task.Run(() => companyResults = companyService.GetAll(Epoch)); 
var t3 = Task.Run(() => contactResults = contactService.GetAll(Epoch)); 
var t4 = Taks.Run(() => ticketResults = ticketService.GetAll(Epoch)); 

await Task.WhenAll(t1,t2,t3,t4); 
//results should be filled here