一連のメソッドを並列に実行する

Question

私はREST APIに接続し、さまざまなオブジェクトを取得するためにいくつかのエンドポイントを呼び出しています。私は、REST APIを呼び出し、結果を得るためにGetAll()を呼び出して、各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()); 

：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()呼び出しを並列に呼び出すことを考えています。理論的には、複数の要求を1つずつ繰り返して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()のを理解していないので、変数が初期化されていないことを警告します。

コンパイラが知っている唯一のことは、その関数にいくつかのラムダを渡すことです。しかし、彼らはいつ実行されるのかを推測することはできません。コンパイラはParallel.Invoke()がすべてActionが完了したときにのみ戻ることを知らない。特にラムダが変数を初期化していることはわかりません。

したがって、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