快捷導航

C#使用Task.ContinueWith組合任務(wù)

更新時間：2022年04月20日 17:02:22 作者：農(nóng)碼一生

這篇文章介紹了C#使用Task.ContinueWith組合任務(wù)的方法，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下

代碼案例

簡單Demo

代碼：

        public static void Main()
        {
            //創(chuàng)建一個任務(wù)
            Task<int> task = new Task<int>(() =>
            {
                int sum = 0;
                Console.WriteLine("使用Task異步執(zhí)行操作.");
                for (int i = 0; i <= 100; i++)
                {
                    sum += i;
                }
                return sum;
            });
            
            //啟動任務(wù),并安排到當前任務(wù)隊列線程中執(zhí)行任務(wù)(System.Threading.Tasks.TaskScheduler)
            task.Start();
            Console.WriteLine("主線程執(zhí)行其他程序.");
           
            //任務(wù)完成時執(zhí)行處理。
            Task cwt = task.ContinueWith(t =>
            {
                Console.WriteLine("任務(wù)完成後的結(jié)果是：{0}", t.Result.ToString());
            });
            task.Wait();
            cwt.Wait();
            Console.ReadLine();
            Console.ReadKey();
        }

結(jié)果：

任務(wù)的串行

代碼：

        static void Main(string[] args)
        {
            ConcurrentStack<int> stack = new ConcurrentStack<int>();

            //t1先串行
            var t1 = Task.Factory.StartNew(() =>
            {
                //入棧
                stack.Push(1);
                stack.Push(2);
            });

            //t2,t3并行執(zhí)行
            var t2 = t1.ContinueWith(t =>
            {
                int result;
                //出棧
                stack.TryPop(out result);
                Console.WriteLine("Task t2 result={0},Thread id {1}", result, Thread.CurrentThread.ManagedThreadId);
            });

            //t2,t3并行執(zhí)行
            var t3 = t1.ContinueWith(t =>
            {
                int result;
                //出棧
                stack.TryPop(out result);
                Console.WriteLine("Task t3 result={0},Thread id {1}", result, Thread.CurrentThread.ManagedThreadId);
            });

            //等待t2和t3執(zhí)行完
            Task.WaitAll(t2, t3);

            //t7串行執(zhí)行
            var t4 = Task.Factory.StartNew(() =>
            {
                Console.WriteLine("當前的集合數(shù)目：{0},Thread id {1}", stack.Count, Thread.CurrentThread.ManagedThreadId);
            });
            t4.Wait();
            Console.ReadKey();
        }

結(jié)果：

子任務(wù)

代碼：

        public static void Main()
        {
            Task<string[]> parent = new Task<string[]>(state =>
            {
                Console.WriteLine(state);
                string[] result = new string[2];
                //創(chuàng)建并啟動子任務(wù)
                new Task(() => { result[0] = "我是子任務(wù)1。"; }, TaskCreationOptions.AttachedToParent).Start();
                new Task(() => { result[1] = "我是子任務(wù)2。"; }, TaskCreationOptions.AttachedToParent).Start();
                return result;
            }, "我是父任務(wù)，並在處理過程中創(chuàng)建多個子任務(wù)，所有的子任務(wù)完成以後我才會開始執(zhí)行。");           
            //任務(wù)處理完成后執(zhí)行的操作
            parent.ContinueWith(t =>
            {
                Array.ForEach(t.Result, r => Console.WriteLine(r));
            });
            //啟動父任務(wù)
            parent.Start();
            //等待任務(wù)結(jié)束 Wait只能等待父線程結(jié)束,沒辦法等到父線程的ContinueWith結(jié)束
            //parent.Wait();
            Console.ReadLine();
        }

結(jié)果：

動態(tài)并行

代碼：

    class Node
    {
        public Node Left { get; set; }
        public Node Right { get; set; }
        public string Text { get; set; }
    }
    class Program
    {
        static Node GetNode()
        {
            Node root = new Node
            {
                Left = new Node
                {
                    Left = new Node
                    {
                        Text = "L-L"
                    },
                    Right = new Node
                    {
                        Text = "L-R"
                    },
                    Text = "L"
                },
                Right = new Node
                {
                    Left = new Node
                    {
                        Text = "R-L"
                    },
                    Right = new Node
                    {
                        Text = "R-R"
                    },
                    Text = "R"
                },
                Text = "Root"
            };
            return root;
        }

        static void Main(string[] args)
        {
            Node root = GetNode();
            DisplayTree(root);
        }

        static void DisplayTree(Node root)
        {
            var task = Task.Factory.StartNew(() => DisplayNode(root),
                                            CancellationToken.None,
                                            TaskCreationOptions.None,
                                            TaskScheduler.Default);
            task.Wait();
        }

        static void DisplayNode(Node current)
        {

            if (current.Left != null)
                Task.Factory.StartNew(() => DisplayNode(current.Left),
                                            CancellationToken.None,
                                            TaskCreationOptions.AttachedToParent,
                                            TaskScheduler.Default);
            if (current.Right != null)
                Task.Factory.StartNew(() => DisplayNode(current.Right),
                                            CancellationToken.None,
                                            TaskCreationOptions.AttachedToParent,
                                            TaskScheduler.Default);
            Console.WriteLine("當前節(jié)點值:{0};處理的Thread ID ={1}", current.Text, Thread.CurrentThread.ManagedThreadId);
        }
    }

結(jié)果：