如何用Task处理10个网络请求.当带宽太慢时
本文关键字:带宽 请求 网络 何用 Task 处理 10个 | 更新日期: 2023-09-27 18:29:50
我正在使用httpClient.GetAsync异步查询10个Web请求我正在使用Task.Any来处理数据,只要10个请求中的一个完成下载
问题是,每个10个请求大约需要2-3秒才能下载和使用任务。任何意味着我的应用程序在下载的同时10个网络请求
如果我的连接带宽很慢,数据的处理就会延迟
解决方案是下载一些请求,例如10个请求中的2个并睡眠其他8个请求。然后,在处理第一个网络请求的同时,继续唤醒其余的网络请求。
我不知道该怎么做现在,我的代码看起来像这个
private async void OnLaunchClick(object sender, RoutedEventArgs e)
{
var quotesTask = new List<Task<IEnumerable<Symbol>>>();
for (int i = 0; i < userInput.Symbols.Count(); i = i + SYMBOLS_PAGINATION_PER_REQUEST)
{
var input = new UserInput(userInput.Symbols.Skip(i).Take(SYMBOLS_PAGINATION_PER_REQUEST), userInput.StartDate, userInput.EndDate, userInput.Interval);
quotesTask.Add(quotesQuery.GetSymbolsInternal(input, _cts.Token));
}
while (quotesTask.Count > 0)
{
Task<IEnumerable<Symbol>> quotesFinishedTask = await Task.WhenAny(quotesTask);
quotesTask.Remove(quotesFinishedTask);
// Update UI
}
}
public async Task<IEnumerable<Symbol>> GetSymbolsInternal(UserInput filteredInput, CancellationToken token)
{
if (filteredInput == null) throw new ArgumentNullException("filteredInput");
string url = BuildUrl(filteredInput);
logger.Debug(string.Format("Start downloading quotes: {0}'n{1}",
filteredInput.Symbols.Select(a => a.Name).Join(","),
url));
string content = await _webRequest.GetData(url, token).ConfigureAwait(false);
logger.Debug(string.Format("End downloading quotes: {0}", filteredInput.Symbols.Select(a => a.Name).Join(",")));
var symbols = Parse(filteredInput.Symbols, content);
return symbols;
}
public class WebRequest
{
private static readonly Logger logger = LogManager.GetCurrentClassLogger();
public virtual async Task<string> GetData(string uri, CancellationToken token)
{
string result = string.Empty;
using (var client = new HttpClient())
using (var response = await client.GetAsync(uri, token).ConfigureAwait(false))
{
if (response.IsSuccessStatusCode)
result = await response.Content.ReadAsStringAsync().ConfigureAwait(false);
else
logger.Error("Unable to retrieve data from the following url: {0} - StatusCode: {1}", uri, response.StatusCode);
}
return result;
}
}
目标是加快下载10个网络请求中的1个,以便尽快处理数据和更新UI,而不是在有限的带宽下同时下载10个Web请求,并且必须在几秒钟后更新UI。
您可以在循环中移动这个:
int tasksToRunAtOnce = 3;
var quotesTasks = new List<Task<IEnumerable<Quote>>();
for(int i=0; i<10;i++)
{
quotesTasks.Add(GetQuotesAsync(i));
if (i < tasksToRunAtOnce - 1)
continue;
var quotesFinished = await Task.WhenAny(quotesTasks);
quotesTasks.Remove(quotesFinished);
// process data for quotesTasks
// update the UI
}
while(quoteTasks.Any())
{
var quotesFinished = await Task.WhenAny(quotesTasks);
quotesTasks.Remove(quotesFinished);
// process data for quotesTasks
// update the UI
}
请注意,我们跳过了第一个元素,因此这将启动tasksToRunAtOnce
任务,然后开始等待,以便第三个元素在前两个元素中的一个完成之前不会启动,等等。