내 웹 API 컨트롤러 <strong>MyController에</strong>에서

Question

[HttpPost] 
    Route("groupmembershipvalidate")] 
    public IHttpActionResult PostGroupMembershipValidate(ListGroupMembershipUploadInput ListGroupMembershipUploadInput) 
    { 

    //perform some tasks 

    var searchResults = ts.validateDetails(gmvi); 

    return Ok(searchResults); 

    } 

지금이 validateDetails 서비스 클래스를 실행하는 데 필요한 내 서비스 클래스에 대한 호출이 일부 작업은 병렬 처리되므로 모든 결과가 돌아올 때까지 기다렸다가 다시 돌아올 때까지 기다려야합니다.

 var tasks = new Task[] 
     { 
      Task.Factory.StartNew(() => gd.validateChapterCodeDetails(_input1)), 
      Task.Factory.StartNew(() => gd.validateGroupCodeDetails(_input1)), 
      Task.Factory.StartNew(() => gd.validateMasterIdDetails(_input1)) 
     }; 

     var things = Task.WhenAll(tasks); 

     //Some tasks 

     return result; 

모든 작업이 결과를 반환 할 때까지 반환되는 결과는 계산되지 않습니다. 그러나 Task.WhenAll (작업)이 눌 렸을 때 즉시 다음 몇 줄로 이동하여 PostGroupMembershipValidate 컨트롤러 메서드로 돌아갑니다.

값을 반환하기 전에 대기하고 모든 값을 가져온 후에 만 ​​반환하는 방법은 무엇입니까?

Answer 1

모든 작업을 사용하여 모든 작업이 완료 될 때 완료되는 새 작업을 만드는 경우 일반 비동기 패턴을 사용하여 해당 작업에서 결과를 가져올 수 있습니다.

https://msdn.microsoft.com/en-us/library/system.threading.tasks.task.whenall(v=vs.110).aspx

그래서 유효성 검사 결과 문자열 // 경우 작업 [] 작업 = ... VAR 것들 =이 Task.WhenAll (작업)을 기다리고 있습니다;

WaitAll을 사용할 수도 있지만 출력 작업이 필요한 경우에는 여기를 클릭하십시오. 어쨌든 비동기 컨텍스트에 머물고있는 IMO는 항상 더 좋습니다.

https://msdn.microsoft.com/en-us/library/dd270695(v=vs.110).aspx

Task.WaitAll(tasks); 
foreach(var t in tasks) DoSomething(t.Result); 

게다가, AFAIK 차단, 현재의 thread.

---

더 완벽한 콘솔 예 : https://dotnetfiddle.net/JMLHxR

using System; 
using System.Threading.Tasks; 

public class Program 
{ 
    private static int counter = 0; 

    public static void Main() 
    { 
     Random rnd = new Random(); 
     var tasks = new Task<object>[] 
     { 
      // If your target method returns a task. 
      // - note: A Proxy or similar approach will probably be more readable. 
      CreateTask(rnd.Next(500,2000)).ContinueWith(t => (object)t.Result), 
      CreateOtherTask(rnd.Next(500,2000)).ContinueWith(t => (object)t.Result), 
      CreateTask(rnd.Next(500,2000)).ContinueWith(t => (object)t.Result), 
      CreateOtherTask(rnd.Next(500,2000)).ContinueWith(t => (object)t.Result), 

      //If your target method is syncronious. 
      Task.Run(() => (object)CreateSimple()), 
      Task.Run(() => (object)CreateMessage()), 
      Task.Run(() => (object)CreateSimple()), 
      Task.Run(() => (object)CreateMessage()) 
     };  

     Task.WaitAll(tasks); 
     foreach(var t in tasks) 
      Console.WriteLine(t.Result); 

     // They are already completed here, but just to show the syntax. 
     // .Result should obvisously be awaited instead. 
     var all = Task.WhenAll(tasks).Result; 
     foreach(var result in all) 
      Console.WriteLine(result); 
    } 


    private static string CreateSimple() 
    { 
     int id = Program.counter++; 
     return "Task [" + id + "] delayed: NONE"; 
    } 

    private static Message CreateMessage() 
    { 
     return new Message(CreateSimple()); 
    } 

    private static async Task<string> CreateTask(int delay) 
    { 
     int id = Program.counter++; 
     await Task.Delay(delay); 
     return "Task [" + id + "] delayed: " + delay; 
    } 

    private static async Task<Message> CreateOtherTask(int delay) 
    { 
     int id = Program.counter++; 
     await Task.Delay(delay); 
     return new Message("Task [" + id + "] delayed: " + delay); 
    } 

    public class Message { 
     private string message; 

     public Message(string msg) { message = msg; } 

     public override string ToString(){ return message; } 
    } 
}