1

httpClient.GetAsync を使用して 10 個の Web リクエストを非同期的にクエリしています。10 個のリクエストの 1 つがダウンロードを完了するとすぐに、Task.Any を使用してデータを処理しています。

問題は、10 個のリクエストごとに、ダウンロードして Task.Any を使用するのに約 2 ～ 3 秒かかるということです。

接続帯域幅が遅いと、データの処理が遅れます

解決策は、いくつかの要求をダウンロードすることです。たとえば、10 個の要求のうち 2 個をダウンロードし、残りの 8 個の要求をスリープ状態にします。次に、最初の Web リクエストを処理している間、残りの Web リクエストをウェイクアップし続けます。

今のところどうすればいいのかわかりません。私のコードは次のようになります

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 個の Web リクエストをダウンロードし、数秒後に UI を更新する必要があるのではなく、データを処理してできるだけ早く UI を更新するために、10 個の Web リクエストのうち 1 つのダウンロードを高速化することです。 .

4

1 に答える 1

2

これをループ内に移動できます：

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タスクが開始され、次に待機が開始されるため、最初の 2 つのうちの 1 つが完了するまで 3 つ目の要素は起動されません。

于 2013-08-31T23:18:21.780 に答える