在并行处理时完成后立即重新启动任务

Question

完成后，我必须立即重新启动所有任务。请在下面查看我的程序；

class Program
    {
         static async Task Main(string[] args)
        {
            int _count = 1;
            while (true)
            {
                await ProcessTasksAsync();
                Console.Write("----Restart Tasks----" + (_count++).ToString() + Environment.NewLine);
                await Task.Delay(2000);
            }
        }

        static async Task ProcessTasksAsync()
        {
            Task<int> taskA = LongTaskA(10);
            Task<int> taskB = MediumTaskB(10);
            Task<int> taskC = ImmediateTaskC(10);

            var tasks = new[] { taskA, taskB, taskC };

            var processingTasks = tasks.Select(AwaitAndProcessAsync).ToList();
            await Task.WhenAll(processingTasks);
        }

        static async Task AwaitAndProcessAsync(Task<int> task)
        {
            var result = await task;
            Console.WriteLine("Return Result: " + result);
        }

        static async Task<int> LongTaskA(int _processingCount)
        {
            for (int i = 0; i < _processingCount; i++)
            {
                Console.Write(string.Format("LongTaskA:{0}", i.ToString()) + Environment.NewLine);
                await Task.Delay(7000);
            }
            return 1;
        }

        static async Task<int> MediumTaskB(int _processingCount)
        {
            for (int i = 0; i < _processingCount; i++)
            {
                Console.Write(string.Format("MediumTaskB:{0}", i.ToString()) + Environment.NewLine);
                await Task.Delay(3000);
            }
            return 2;
        }

        static async Task<int> ImmediateTaskC(int _processingCount)
        {
            for (int i = 0; i < _processingCount; i++)
            {
                Console.Write(string.Format("ImmediateTaskC:{0}", i.ToString()) + Environment.NewLine);
                await Task.Delay(1000);
            }
            return 3;
        }

    }

任务A，B＆amp; C运行可行。但是，即使完成后，某些任务的完成也不会重新启动。当我使用“ wheral”时，它等待完成另一个任务。

我想在完成后重新启动每个任务。我该如何实现？

谢谢， Shenu

Answer 1

您的程序当前同时运行这三个任务，（异步）等待它们都完成，然后在循环中执行此操作。

如果要在循环中运行每个任务，则只需移动循环：

static async Task ProcessTasksAsync()
{
  Task<int> taskA = LoopA(10);
  Task<int> taskB = LoopB(10);
  Task<int> taskC = LoopC(10);

  await Task.WhenAll(taskA, taskB, taskC);
}

static async Task LoopA()
{
  while (true)
    await AwaitAndProcessAsync(LongTaskA(10));
}

static async Task LoopB()
{
  while (true)
    await AwaitAndProcessAsync(MediumTaskB(10));
}

static async Task LoopC()
{
  while (true)
    await AwaitAndProcessAsync(ImmediateTaskC(10));
}