いろいろ備忘録日記

主に .NET とか Go とか Flutter とか Python絡みのメモを公開しています。

タスク並列ライブラリ入門記-005 (Task.Run, .NET 4.5から追加されたタスク開始方法)

C#

.NET 4.5からタスクの開始方法に新しいメソッドが用意されました。

Task.Run(...) // ActionとかFuncとかCancellationTokenとか

.NET 4.0のときは

Task.Factory.StartNew(...)

を利用してタスクを構築するショートカットがありましたが
それに加えて、Task.Runの形式も追加されました。
個人的には、Task.Runの形式の方が分かりやすくて好きです。

以下、サンプルです。

namespace Sazare.Samples
{
  using System;
  using System.Collections.Generic;
  using System.Linq;
  using System.Threading;
  using System.Threading.Tasks;

  using Sazare.Common;

  /// <summary>
  /// タスク並列ライブラリについてのサンプルです。
  /// </summary>
  /// <remarks>
  /// タスク並列ライブラリは、.NET 4.0から追加されたライブラリです。
  /// Task.Runメソッドは、.NET 4.5から追加されたメソッドです。
  /// </remarks>
  [Sample]
  class TaskSamples05 : IExecutable
  {
    public void Execute()
    {
      //
      // .NET 4.5からタスクの開始方法に
      //    Task.Run
      // メソッドが追加された。
      // 以前のTask.Factory.StartNewメソッドと
      // 同様に利用する事ができる。
      //
      // http://msdn.microsoft.com/ja-jp/library/system.threading.tasks.task.run(v=vs.110).aspx
      //

      //
      // 引数にActionを指定（最もシンプルなパターン)
      //
      Task.Run(() => Output.WriteLine("Task.Run(Action)")).Wait();

      //
      // 引数にFuncを指定
      //
      var task1 = Task.Run(() => 100);
      Output.WriteLine(task1.Result);

      //
      // C# 5.0のasync/awaitを利用.
      //  サンプルの都合上RunAsyncの呼び出しはawaitしていない
      //
      RunAsync();

      //
      // 上の記述のAwaiter版
      //   サンプルの都合上わざとtask2の完了待ちをしている
      //
      var task2   = Task.Run(() => 300);
      var awaiter = task2.GetAwaiter();
      awaiter.OnCompleted(() =>
        {
          Output.WriteLine(awaiter.GetResult());
        }
      );

      task2.Wait();

      //
      // Task.RunメソッドにはAction, Funcを指定して、且つ、CancellationTokenを
      // 指定することもできる。
      //
      var tokenSource = new CancellationTokenSource();
      var token       = tokenSource.Token;

      var printDot = new Action(() =>
        {
          while (true)
          {
            if (token.IsCancellationRequested)
            {
              Output.WriteLine(string.Empty);
              break;
            }

            Output.Write(".");
            Thread.Sleep(TimeSpan.FromMilliseconds(500));
          }
        }
      );

      var task3 = Task.Run(printDot, token);
      
      Thread.Sleep(TimeSpan.FromSeconds(3));
      tokenSource.Cancel();

      task3.Wait();
      tokenSource.Dispose();
    }

    async Task RunAsync()
    {
      int result = await Task.Run(() => 200);
      Output.WriteLine(result);
    }
  }
}

実行結果は、以下のようになります。

================== START ==================
Task.Run(Action)
100
200
300
......
==================  END  ==================

アップした以前の記事は以下からご参照くださいませ。

  • タスク並列ライブラリ(TPL)についてのリソース (Task Parallel Library, Parallel.For, Thread, ThreadPool, 非同期, 並列)
  • タスク並列ライブラリ入門記-000 (事始め, 殴り書きメモ)
  • タスク並列ライブラリ入門記-001 (タスクの実行, TPL, Task.Factory.StartNew, Wait, WaitAll)
  • タスク並列ライブラリ入門記-002 (タスクの実行, TPL, Task.ctor, Wait, WaitAll)
  • タスク並列ライブラリ入門記-003 (タスクの入れ子, デタッチされた入れ子のタスク, 親のタスクとの関連を持たない, TaskCreationOptions.None)
  • タスク並列ライブラリ入門記-004 (タスクの入れ子, 親のタスクにアタッチされた入れ子タスク, 親のタスクとの関連を持つ, TaskCreationOptions.AttachedToParent)

過去の記事については、以下のページからご参照下さい。

サンプルコードは、以下の場所で公開しています。