第六節：深入研究Task實例方法ContinueWith的參數TaskContinuationOptions

一. 整體說明

揭秘：

　　該章節的性質和上一個章節類似，也是一個擴展的章節，主要來研究Task類下的實例方法ContinueWith中的參數TaskContinuationOptions。

　　通過F12查看TaskContinuationOptions的源碼，知道主要有這么幾個參數：

　　①. LazyCancellation：在延續取消的情況下，防止延續的完成直到完成先前的任務。

　　　　(下面的例子task2取消，原先的延續關系不復存在，task1和task3可以並行執行)

　　②. ExecuteSynchronously：希望執行前面那個task的thread也在執行本延續任務

　　　　(下面的例子執行task2的Thread和執行task1的Thread是同一個，所有二者的線程id相同)

　　③. NotOnRanToCompletion和OnlyOnRanToCompletion

　　　　NotOnRanToCompletion：延續任務必須在前面task非完成狀態才能執行

　　　　OnlyOnRanToCompletion：延續任務必須在前面task完成狀態才能執行

　　　　(下面例子：注釋掉異常的這句代碼task2不能執行，task3能執行；不注釋，task2能執行，task3不能執行)

 源碼如下：

 [Serializable]
    [Flags]
    public enum TaskContinuationOptions
    {
        // 摘要: 
        //     Default = "Continue on any, no task options, run asynchronously" 指定應使用默認行為。
        //     默認情況下，完成前面的任務之后將安排運行延續任務，而不考慮前面任務的最終 System.Threading.Tasks.TaskStatus。
        None = 0,
        //
        // 摘要: 
        //     提示 System.Threading.Tasks.TaskScheduler 以一種盡可能公平的方式安排任務，這意味着較早安排的任務將更可能較早運行，而較晚安排運行的任務將更可能較晚運行。
        PreferFairness = 1,
        //
        // 摘要: 
        //     指定某個任務將是運行時間長、粗粒度的操作。 它會向 System.Threading.Tasks.TaskScheduler 提示，過度訂閱可能是合理的。
        LongRunning = 2,
        //
        // 摘要: 
        //     指定將任務附加到任務層次結構中的某個父級。
        AttachedToParent = 4,
        //
        // 摘要: 
        //     如果嘗試附有子任務到創建的任務，指定 System.InvalidOperationException 將被引發。
        DenyChildAttach = 8,
        //
        // 摘要: 
        //     防止環境計划程序被視為已創建任務的當前計划程序。 這意味着像 StartNew 或 ContinueWith 創建任務的執行操作將被視為 System.Threading.Tasks.TaskScheduler.Default
        //     當前計划程序。
        HideScheduler = 16,
        //
        // 摘要: 
        //     在延續取消的情況下，防止延續的完成直到完成先前的任務。
        LazyCancellation = 32,
        //
        // 摘要: 
        //     指定不應在延續任務前面的任務已完成運行的情況下安排延續任務。 此選項對多任務延續無效。
        NotOnRanToCompletion = 65536,
        //
        // 摘要: 
        //     指定不應在延續任務前面的任務引發了未處理異常的情況下安排延續任務。 此選項對多任務延續無效。
        NotOnFaulted = 131072,
        //
        // 摘要: 
        //     指定只應在延續任務前面的任務已取消的情況下才安排延續任務。 此選項對多任務延續無效。
        OnlyOnCanceled = 196608,
        //
        // 摘要: 
        //     指定不應在延續任務前面的任務已取消的情況下安排延續任務。 此選項對多任務延續無效。
        NotOnCanceled = 262144,
        //
        // 摘要: 
        //     指定只應在延續任務前面的任務引發了未處理異常的情況下才安排延續任務。 此選項對多任務延續無效。
        OnlyOnFaulted = 327680,
        //
        // 摘要: 
        //     指定只應在延續任務前面的任務已完成運行的情況下才安排延續任務。 此選項對多任務延續無效。
        OnlyOnRanToCompletion = 393216,
        //
        // 摘要: 
        //     指定應同步執行延續任務。 指定此選項后，延續任務將在導致前面的任務轉換為其最終狀態的相同線程上運行。 如果在創建延續任務時已經完成前面的任務，則延續任務將在創建此延續任務的線程上運行。
        //     只應同步執行運行時間非常短的延續任務。
        ExecuteSynchronously = 524288,
    }

 

二. 實際測試

 　　下面通過代碼來說明默認情況下、LazyCancellation、ExecuteSynchronously、NotOnRanToCompletion和OnlyOnRanToCompletion的作用和效果。

1. 默認情況

 　　默認情況下，task1執行完后→task2→task2執行完后→task3。　　

            {
                Task task1 = new Task(() =>
                {
                    Thread.Sleep(1000);
                    Console.WriteLine("task1 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                });

                var task2 = task1.ContinueWith(t =>
                {
                    Console.WriteLine("task2 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                });

                var task3 = task2.ContinueWith(t =>
                {
                    Console.WriteLine("task3 tid={0}， dt={1}  {2}", Thread.CurrentThread.ManagedThreadId, DateTime.Now, task2.Status);
                });

                task1.Start();

            }

 運行結果： task1執行完后→ task2執行→task2執行完后→ task3執行。

2. LazyCancellation

 　　作用：取消該線程，該線程的前一個線程和后一個線程並行執行。

            {
                CancellationTokenSource source = new CancellationTokenSource();
                source.Cancel();

                Task task1 = new Task(() =>
                {
                    Thread.Sleep(1000);
                    Console.WriteLine("task1 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                });

                var task2 = task1.ContinueWith(t =>
                {
                    Console.WriteLine("task2 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                }, source.Token, TaskContinuationOptions.LazyCancellation, TaskScheduler.Current);

                var task3 = task2.ContinueWith(t =>
                {
                    Console.WriteLine("task3 tid={0}， dt={1}  {2}", Thread.CurrentThread.ManagedThreadId, DateTime.Now, task2.Status);
                });

                task1.Start();

            }

  運行結果： task2線程已經被取消，task1線程和task2線程並行執行。

3. ExecuteSynchronously

 　　作用：希望執行前面那個task的thread也在執行本延續任務。

  {
                Task task1 = new Task(() =>
                {
                    Thread.Sleep(1000);
                    Console.WriteLine("task1 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                });

                var task2 = task1.ContinueWith(t =>
                {
                    Console.WriteLine("task2 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                }, TaskContinuationOptions.ExecuteSynchronously);

                task1.Start();
}

 　　結果：task1和task2線程的線程id相同。

4. NotOnRanToCompletion和OnlyOnRanToCompletion　

　　NotOnRanToCompletion：延續任務必須在前面task非完成狀態才能執行。

　　OnlyOnRanToCompletion：延續任務必須在前面task完成狀態才能執行。

     {
                Task task1 = new Task(() =>
                    {
                        Thread.Sleep(1000);
                        Console.WriteLine("task1 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                        //手動制造異常，表示不能執行完畢
                        //（注釋掉這句話task2不能執行，task3能執行）
                        //不注釋，task2能執行，task3不能執行
                        //throw new Exception("hello world");
                    });

                var task2 = task1.ContinueWith(t =>
                {
                    Console.WriteLine("task2 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                }, TaskContinuationOptions.NotOnRanToCompletion);

                var task3 = task1.ContinueWith(t =>
                {
                    Console.WriteLine("task3 tid={0}， dt={1}", Thread.CurrentThread.ManagedThreadId, DateTime.Now);
                }, TaskContinuationOptions.OnlyOnRanToCompletion);

                task1.Start();
}

　　分析：task2和task3均為task的延續線程，當task1報錯時候，task2執行，task3不能執行；當task1正常時候，task2不能執行，task3能執行。

　　task1報錯時的運行結果：

　　task2正常時的運行結果：