非同期呼び出しを使用してSOAPサービスを呼び出すのを待ちます。

Question

SOAPアプリケーションを呼び出すために、Webアプリケーションで非同期待機を実装しようとしています。私はデータベースに呼び出しを行うときにうまく動作する依存性注入を実装しています。 私はwebserviceを呼び出すときに私は応答を取得しますが、一度クエリが存在するとデッドロックです。私は何がうまくいかないのか理解できません。私はこの非同期のものにあなたの入力を高く評価して初めてです。 これは私がコール

public void GetPersonData() 
{ 
    var persons = queryProcessor.Process(new GetPersonsWhichNeedApiCalls()); 
    var watch = System.Diagnostics.Stopwatch.StartNew(); 
    // the code that you want to measure comes here 
    SearchAPI(persons).Wait(); 
    watch.Stop(); 
    var elapsedMs = watch.ElapsedMilliseconds; 
} 

private async Task SearchAPI(IEnumerable<Person> persons) 
{ 
    var tasks = persons.Select(async eachPerson => 
    { 
     var result = await asyncQueryProcessor.ProcessAsync(new PersonSearchCall { Name = eachPerson.Name, Id = eachPerson.Id }); 
     commandProcessor.Process(new CreatePersonSearch() 
     { 
      PersonSearch = result 
     }); 
    }); 
    await Task.WhenAll(tasks); 

} 

クエリ呼び出すためにMVCアプリケーションでのサービスを呼び出しています方法です：

namespace Sample.AsyncQueries 
{ 
    public class PersonSearchCall : IQuery<PersonSearch> 
    { 
     public string Name { get; set; } 
     public int Id { get; set; } 
    } 

    public class PersonSearchCallHandler : IAsyncQueryHandler<PersonSearchCall, PersonSearch> 
    { 
     private readonly IQueryProcessor queryProcessor; 
     private readonly ICommandProcessor commandProcessor; 

     public PersonSearchCallHandler(ICommandProcessor commandProcessor, 
      IQueryProcessor queryProcessor) 
     { 
      this.queryProcessor = queryProcessor; 
      this.commandProcessor = commandProcessor; 
     } 

     public async Task<PersonSearch> HandleAsync(PersonSearchCall query) 
     { 
      var client = new PersonServiceSoapClient(); 

      var personResponses = await client.PersonSearchAsync(inputs).ConfigureAwait(false); 
      //Build the person Object 
      return person; 
     } 
    } 
} 

私は同期の方法を使用してこれを達成することができました。このシンプルインジェクタしかし、私としては人のリストを呼び出しており、各コールは約2秒かかります。私は非同期の使用を利用しようとしており、リストから複数の呼び出しを行うのを待っています。

Answer 1

StriplingWarriorがコメントしたように、問題はあなたがblocking on async codeだということです。あなたはasync all the wayを使用する必要があります。

public async Task GetPersonData() 
{ 
    var persons= queryProcessor.Process(new GetPersonsWhichNeedApiCalls()); 
    var watch = System.Diagnostics.Stopwatch.StartNew(); 
    await SearchAPI(persons); 
    var elapsedMs = watch.ElapsedMilliseconds; 
}