嵌套线程（任务）过早超时

Question

我有以下代码，我认为它的作用并不重要，但我的行为很奇怪。

当我在单独的线程上运行几个月时，它运行良好（如下所示），但是当我多线程几年（取消注释任务）时，它每次都会超时。超时设置为月 5 分钟/年 20 分钟，并在一分钟内超时。

这种行为是否有已知原因？我错过了一些简单的东西吗？

    public List<PotentialBillingYearItem> GeneratePotentialBillingByYear()
    {
        var years = new List<PotentialBillingYearItem>();
        //var tasks = new List<Task>();
        var startYear = new DateTime(DateTime.Today.Year - 10, 1, 1);
        var range = new DateRange(startYear, DateTime.Today.LastDayOfMonth());

        for (var i = range.Start; i <= range.End; i = i.AddYears(1))
        {
            var yearDate = i;
            //tasks.Add(Task.Run(() =>
            //{
                years.Add(new PotentialBillingYearItem
                {
                    Total = GeneratePotentialBillingMonths(new PotentialBillingParameters { Year = yearDate.Year }).Average(s => s.Total),
                    Date = yearDate
                });
            //}));
        }

        //Task.WaitAll(tasks.ToArray(), TimeSpan.FromMinutes(20));

        return years;
    }

    public List<PotentialBillingItem> GeneratePotentialBillingMonths(PotentialBillingParameters Parameters)
    {
        var items = new List<PotentialBillingItem>();
        var tasks = new List<Task>();
        var year = new DateTime(Parameters.Year, 1, 1);
        var range = new DateRange(year, year.LastDayOfYear());

        range.Start = range.Start == range.End ? DateTime.Now.FirstDayOfYear() : range.Start.FirstDayOfMonth();

        if (range.End > DateTime.Today) range.End = DateTime.Today.LastDayOfMonth();

        for (var i = range.Start; i <= range.End; i = i.AddMonths(1))
        {
            var firstDayOfMonth = i;
            var lastDayOfMonth = i.LastDayOfMonth();
            var monthRange = new DateRange(firstDayOfMonth, lastDayOfMonth);
            tasks.Add(Task.Run(() =>
            {
                using (var db = new AlbionConnection())
                {

                    var invoices = GetInvoices(lastDayOfMonth);

                    var timeslipSets = GetTimeslipSets();

                    var item = new PotentialBillingItem
                    {
                        Date = firstDayOfMonth,
                        PostedInvoices = CalculateInvoiceTotals(invoices.Where(w => w.post_date <= lastDayOfMonth), monthRange),
                        UnpostedInvoices = CalculateInvoiceTotals(invoices.Where(w => w.post_date == null || w.post_date > lastDayOfMonth), monthRange),
                        OutstandingDrafts = CalculateOutstandingDraftTotals(timeslipSets)
                    };

                    items.Add(item);
                }
            }));
        }

        Task.WaitAll(tasks.ToArray(), TimeSpan.FromMinutes(5));

        return items;
    }

Answer 1

您可以考虑预先分配更多的线程池线程。线程池分配新线程的速度非常慢。将线程池线程的最小数量设置为 2.5k 的任务下面的代码只需 10 秒（理论上的最小值）即可运行，但注释掉 SetMinThreads 会使它花费超过 1:30 秒。

static void Main(string[] args)
{
    ThreadPool.SetMinThreads(2500, 10);
    Stopwatch sw = Stopwatch.StartNew();
    RunTasksOutter(10);
    sw.Stop();
    Console.WriteLine($"Finished in {sw.Elapsed}");
}

public static void RunTasksOutter(int num) => Task.WaitAll(Enumerable.Range(0, num).Select(x => Task.Run(() => RunTasksInner(10))).ToArray());
public static void RunTasksInner(int num) => Task.WaitAll(Enumerable.Range(0, num).Select(x => Task.Run(() => Thread.Sleep(10000))).ToArray());

您也可能用完了线程池线程。 Per：https://msdn.microsoft.com/en-us/library/0ka9477y(v=vs.110).aspx 不使用线程池（由任务使用）的时间之一是：

您的任务会导致线程长时间阻塞。线程池具有最大线程数，因此大量阻塞的线程池线程可能会阻止任务启动。

既然 IO 正在这些线程上完成，是否可以考虑用异步代码替换它们或使用 LongRunning 选项启动它们？ https://msdn.microsoft.com/en-us/library/system.threading.tasks.taskcreationoptions(v=vs.110).aspx