0

.NET 4.0 Async CTP で C# コード例「方法: 事前に計算されたタスクを作成する」(MSDN)を実行しようとして、次の変更を行いました。

  • Task.FromResult--->TaskEx.FromResult
  • Task.FromResult--->TaskEx.FromResult
  • Task.Run(async () => ---> TaskEx.RunEx(async () =>
    (こちらも試しましたTaskEx.Run(async () =>)

コンパイルエラーが発生します：

' System.Func<System.Threading.Tasks.Task>' は非同期で Task を返すため、return キーワードの後に​​オブジェクト式を続けてはいけません

この例を実行するためにコードを変更するにはどうすればよいですか? 

using System;
using System.Collections.Concurrent;
using System.Diagnostics;
using System.Linq;
using System.Net;
using System.Threading.Tasks;

// Demonstrates how to use Task<TResult>.FromResult to create a task  
// that holds a pre-computed result. 
class CachedDownloads
{
  // Holds the results of download operations. 
  static ConcurrentDictionary<string, string> cachedDownloads =
     new ConcurrentDictionary<string, string>();

  // Asynchronously downloads the requested resource as a string. 
  public static Task<string> DownloadStringAsync(string address)
  {
    // First try to retrieve the content from cache. 
    string content;
    if (cachedDownloads.TryGetValue(address, out content))
    {

      return TaskEx //****** Task.FromResult ---> TaskEx.FromResult   
             .FromResult<string>(content);
    }

    // If the result was not in the cache, download the  
    // string and add it to the cache. 
    return TaskEx.RunEx //****** Task.Run  --> TaskEx.RunEx (TaskEx.Run)
      (async () =>    
    {
      content = await new WebClient().DownloadStringTaskAsync(address);
      cachedDownloads.TryAdd(address, content);
      return content;//*****Error
    });
  }

  static void Main(string[] args)
  {
    // The URLs to download. 
    string[] urls = new string[]
      {
         "http://msdn.microsoft.com",
         "http://www.contoso.com",
         "http://www.microsoft.com"
      };

    // Used to time download operations.
    Stopwatch stopwatch = new Stopwatch();

    // Compute the time required to download the URLs.
    stopwatch.Start();
    var downloads = from url in urls
                    select DownloadStringAsync(url);
    TaskEx.WhenAll(downloads)//*** Task.WhenAll -->  TaskEx.WhenAll
          .ContinueWith(results =>
    {
      stopwatch.Stop();

      // Print the number of characters download and the elapsed time.
      Console.WriteLine
            ("Retrieved {0} characters. Elapsed time was {1} ms."
              , results.Result.Sum(result => result.Length)
              , stopwatch.ElapsedMilliseconds);
    })
    .Wait();

    // Perform the same operation a second time. The time required 
    // should be shorter because the results are held in the cache.
    stopwatch.Restart();
    downloads = from url in urls
                select DownloadStringAsync(url);

    TaskEx.WhenAll(downloads)//*** Task.WhenAll -->  TaskEx.WhenAll
          .ContinueWith(results =>
    {
      stopwatch.Stop();

      // Print the number of characters download and the elapsed time.
      Console.WriteLine("Retrieved {0} characters. Elapsed time was {1} ms.",
         results.Result.Sum(result => result.Length),
         stopwatch.ElapsedMilliseconds);
    })
    .Wait();
  }
}

アップデート：

Async CTP の更新を行わないこのコード例は、.NET 4.5 で実行されますか?

4

1 に答える 1

3

C# コンパイラは VS2012 で拡張され、asyncラムダ (Func<Task>およびファミリ) が存在する場合の一般的なオーバーロードの解決がよりスマートになりました。VS2010 を使用しているため、あちこちでそれを支援する必要があります。

手がかりは、asyncエラー メッセージに表示されているラムダの型にあります: System.Func<System.Threading.Tasks.Task>.

あるべき姿はSystem.Func<System.Threading.Tasks.Task<System.String>>.

だから私はこれを試してみます：

return TaskEx.RunEx<string> //****** Task.Run  --> TaskEx.RunEx (TaskEx.Run)
  (async () =>    
{
  content = await new WebClient().DownloadStringTaskAsync(address);
  cachedDownloads.TryAdd(address, content);
  return content;//*****Error
});
于 2013-05-07T18:19:01.997 に答える