创建计算线程总数和限制数量的异步方法

Question

我正在尝试在我的 C# 应用程序中创建一个异步方法，并希望使用有限的线程来实现该方法，该方法应该在单独的线程中计算每个数组的许多数组的总和，但如果我们有超过 4 个（例如 6 个）数组，首先运行4 线程，一旦释放一个线程，您就需要再运行一个线程，依此类推。

这是我的代码：

static int CalculateRouter(Route route)
        {
            int total = route.sum(route.routers);
            return total;
        }

通过计算总时间异步计算最佳路线的异步方法 单独线程中的每个路由都需要。

 public async Task <int> AsyncBestRoute(List<Route> Routes)
        {
            var tasks = new List<Task<int>>();
            foreach (var route in Routes)
            {
                tasks.Add(Task.Run(() => CalculateRouter(route)));
            }
            int[] results = await Task.WhenAll(tasks);
            int minValue = results.Min();
            Console.WriteLine(minValue);
            Console.WriteLine("********************");

            return await Task.FromResult(minValue);
        }

我的工作方法正确吗？我怎么能不限制线程呢？这是我第一次在其中工作，不知道应该如何拖延，有什么帮助或想法吗？

Answer 1

我正在尝试在我的 C# 应用程序中创建一个异步方法，并希望使用有限的线程来实现该方法，该方法应该在单独的线程中计算每个数组的许多数组的总和，但是如果我们有超过 4 个（例如 6 个）数组，首先，您运行 4 个线程，一旦释放一个线程，您需要再运行一个线程，依此类推。

首先：异步与并行有很大不同，尽管它们都是并发形式。异步的重点是使用更少线程，而并行性是使用更多线程。

由于您正在处理受 CPU 限制的操作（求和值），因此您需要并行性，而不是异步性。 Parallel 和 PLINQ 是这里合适的工具。一般来说，如果您有结果（或结果序列），PLINQ 会更干净一些。 Parallel 和 PLINQ 都支持限制线程数量。

public int BestRoute(List<Route> Routes)
{
  return Routes.AsParallel()
      .WithDegreeOfParallelism(4)
      .Select(CalculateRouter)
      .Min();
}

如果您还需要异步，例如，如果您需要释放UI线程，那么您可以使用await和Task.Run :

// Run BestRoute on a thread pool thread to avoid blocking the UI
var minValue = await Task.Run(() => BestRoute(routes));