c# – System.Timers.Timer在Console App中使用带有异步的Task.R

我正在使用一个控制台应用程序,我需要读取20个URI的批次,并且通过完成所有任务并并行运行它们然后在不同的线程中对结果进行排序(允许下一个),我发现了大量的速度提升要获取的批次).

在我当前使用的调用中,每个线程在获得响应流时都会阻塞,我也看到有相同方法GetResponseAsync的异步版本.

我知道通过使用async Await and Async in same line而不是阻塞来释放线程池有好处：

异步版

return Task.Run(async () =>
{
    var uri = item.Links.Alternate();
    var request = (HttpWebRequest)WebRequest.Create(uri);

    var response = await request.GetResponseAsync();
    var stream = response.GetResponseStream();
    if (stream == null) return null;
    var reader = new StreamReader(stream);
    return new FetchItemTaskResult(reader.ReadToEnd(),index,uri);
});

阻止版本

return Task<FetchItemTaskResult>.Factory.StartNew(() =>
{
    var uri = item.Links.Alternate();
    var request = (HttpWebRequest)WebRequest.Create(uri);

    var response = request.GetResponse();
    var stream = response.GetResponseStream();
    if (stream == null) return null;
    var reader = new StreamReader(stream);
    return new FetchItemTaskResult(reader.ReadToEnd(),uri);
});

但是我在控制台应用程序上看到了异常版本的奇怪暂停,其中System.Timers.Timer已经过去的事件停止被调用了很多秒(当它应该每秒关闭时).

阻塞的每秒运行大约3,500个项目,所有核心的CPU使用率约为30％.

async on每秒运行大约3,800个事件,CPU使用率略高于阻塞但不是很多(仅为5％)…但是我使用的计时器似乎每分钟暂停一次大约10到15秒或者,在我的Main()函数中：

private static void Main(string[] args)
{  
    // snip some code that runs the tasks

    var timer = new System.Timers.Timer(1000);

    timer.Elapsed += (source,e) =>
    {
        Console.WriteLine(DateTime.UtcNow);

        // snip non relevant code
        Console.WriteLine("Commands processed: " + commandsProcessed.Sum(s => s.Value) + " (" + logger.CommandsPerSecond() + " per second)");
    };
    timer.Start();
    Console.ReadKey();
}

所以看起来计时器和线程池是一些在使用异步时的相关性(并且只有异步,阻塞时没有暂停),或者可能没有,无论是任何想法,请问是什么以及如何进一步诊断？

ThreadPool.SetMinThreads(100,100);
ServicePointManager.DefaultConnectionLimit = 1000;