C# 6 작업 및 모든 하위 작업의 전체 완료를 기다리는 중

Question

여러 작업을 순서대로 실행하는 일종의 스케줄러 (관련 용어가 아닐 수도 있음)를 구축하려고합니다. 여기

는 (가난 큐/디큐 메커니즘을 무시하지만, 여기 문제가 아니라 내가 생각하시기 바랍니다) 내 POC 코드

편집 : @Theraot

static void Main(string[] args) 
    { 
     ProcessingQueue o_q = new ProcessingQueue(); 
     o_q.Enqueue(async() => { await SimulateTaskSequence(1); }); 
     o_q.Enqueue(async() => { await SimulateTaskSequence(2); }); 

     Console.ReadLine(); 
    } 

    public static async Task SimulateTaskSequence(int taskNbr) 
    { 
     Console.WriteLine("T{0} - Working 1sec", taskNbr); 
     Thread.Sleep(1000); 

     Console.WriteLine("T{0} - Zzz 1st 1sec", taskNbr); 
     await Task.Delay(1000); 

     Console.WriteLine("T{0} - Working 1sec", taskNbr); 
     Thread.Sleep(1000); 

     Console.WriteLine("T{0} - Done", taskNbr); 
    } 

    public class ProcessingQueue 
    { 
     Queue<Action> _Queue = new Queue<Action>(); 
     private bool _stillRunning = false; 

     public void Enqueue(Action a) 
     { 
      lock (_Queue) 
      { 
       _Queue.Enqueue(a); 

       if (_stillRunning == false) 
       { 
        StartProcessing(); 
       } 
      } 
     } 


     private void StartProcessing() 
     { 
      _stillRunning = true; 

      Task.Run(async() => 
      { 
       Action a = null; 

       while (true) 
       { 
        lock (_Queue) 
        { 
         if (_Queue.Any() == true) 
         { 
          a = _Queue.Dequeue(); 
         } 
         else 
         { 
          break; 
         } 
        } 

        await Task.Run(a); //how to wait for all subtasks!!??? 
       } 
       _stillRunning = false; 
      }); 
     } 

내 문제의 도움 덕분에 첫 번째 작업 (T1)을 기다리는 즉시 두 번째 작업 (T2)이 실행되기 시작합니다.

나는 다음과 같은 출력 얻을 :

T1 - Working 1sec 
T1 - Zzz 1st 1sec 
T2 - Working 1sec 
T2 - Zzz 1st 1sec 
T1 - Working 1sec 
T1 - Done 
T2 - Working 1sec 
T2 - Done 

을하지만 난 것 기대하고있어 :

T1 - Working 1sec 
T1 - Zzz 1st 1sec 
T1 - Working 1sec 
T1 - Done 
T2 - Working 1sec 
T2 - Zzz 1st 1sec 
T2 - Working 1sec 
T2 - Done 

나는이 기본 동작 이유를 이해하지만, 나는 그것을 변경해야합니다. 나는 새로운 TaskFactory에서 TaskContinuationOptions와 TaskCreationOptions를 놀고 있었지만 더 좋은 결과는 없었다. 그게 가능합니까?

덕분에 많은 크리스토프

Answer 1

나는 ProcessingQueue<Func<Task>> 대신을 만드는 제안 ProcessingQueue<Action>

public class ProcessingQueue 
{ 
    Queue<Func<Task>> _Queue = new Queue<Func<Task>>(); 

    private bool _stillRunning = false; 

    public void Enqueue(Func<Task> a) 
    { 
     lock (_Queue) 
     { 
      _Queue.Enqueue(a); 

      if (_stillRunning == false) 
      { 
       StartProcessing(); 
      } 
     } 
    } 

    private void StartProcessing() 
    { 
     _stillRunning = true; 

     Task.Run(async() => 
     { 
      Func<Task> a = null; 

      while (true) 
      { 
       lock (_Queue) 
       { 
        if (_Queue.Any() == true) 
        { 
         a = _Queue.Dequeue(); 
        } 
        else 
        { 
         break; 
        } 
       } 

       await a(); //how to wait for all subtasks!!??? 
      } 
      _stillRunning = false; 
     }); 
    } 

설명 문제로 작성된 코드에서

,

Action a; 
... 
await Task.Run(a); 

작업에 작업이 없기 때문에 작업에 비동기 작업이 포함될 수 있으므로 Run 메서드는 작업을 기다리지 않으므로 Task.Run(Action action)을 실행하고 있습니다. Task.Run(Func<Task> task)Run 메서드를 호출하면 해당 메서드가 작업임을 알게되고