並行運行一系列方法

Question

我正在連接到一個REST API並調用一些端點來獲取不同的對象。我爲每一個類型RestService<T>我想下載：

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>然後我打電話GetAll()調用REST API，並得到結果：

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

幕後GetAll()背後，使得一些的HttpWebRequest resquests。

所以我在想的是以某種方式並行調用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()。

所以編譯器知道的唯一事情就是你將一些lambda函數傳遞給該函數。但它無法推斷出它們何時會被執行。編譯器不知道Parallel.Invoke()僅在所有Action完成時纔會返回。它特別不知道你的lambda正在初始化變量。

因此，從編譯器的角度來看，即使在Parallel.Invoke()之後，您尚未將任何值分配給您的變量。

最簡單的方法是簡單地用默認值（null）手動initalize他們：

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