多线程编程学习笔记——async和await

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading; 

namespace ThreadAsyncDemo
{

    class Program
    {
        static void Main(string[] args)
        {

 Console.WriteLine(string.Format("----- 对连续的异步任务使用await操作符----"));

            Task t = AsyncWithTPL();
            t.Wait();
            t = AsyncWithAwait();
            t.Wait();
            Console.Read();          
        }

 

        static Task AsyncWithTPL()
        {
            var containerTask = new Task(() =>
            {
                Task<string> task1 = GetInfoAsync("TPL Task 1");

                task1.ContinueWith(task =>
                {
                    Console.WriteLine(task1.Result);

                    Task<string> task2 = GetInfoAsync("TPL Task 2");
                    task2.ContinueWith(innerTask =>
              Console.WriteLine(innerTask.Result), TaskContinuationOptions.NotOnFaulted | TaskContinuationOptions.AttachedToParent);

                    task2.ContinueWith(innerTask =>
Console.WriteLine(innerTask.Exception.InnerException), TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.AttachedToParent); 

                }, TaskContinuationOptions.NotOnFaulted | TaskContinuationOptions.AttachedToParent);
                task1.ContinueWith(task =>
              Console.WriteLine(task1.Exception.InnerException), TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.AttachedToParent);
            }
            );
            containerTask.Start();
            return containerTask;
        }
        async static Task AsyncWithAwait()
        {
            try
            {
                string result = await GetInfoAsync("Async Task 1");
                Console.WriteLine(result);
                 result = await GetInfoAsync("Async Task 2");
                Console.WriteLine(result);
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
        }
 
        async static Task<string> GetInfoAsync(string name)
        {
            Console.WriteLine(string.Format("任务 {0} 开始。。。",name));
            await Task.Delay(TimeSpan.FromSeconds(2));
            if(name== "TPL Task 2")
            throw new Exception(string.Format("{0} 抛出异常信息！", name));
            return string.Format(" Task {0} 正在运行在线程 ID={1}上。这个工作线程是否是线程池中的线程：{2}", name,
 Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
        }
    }
}

 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Threading; 

namespace ThreadAsyncDemo
{

    class Program
    {

        static void Main(string[] args)
        {
            Console.WriteLine(string.Format("-----    对并行执行的异步任务使用await操作符----"));
            Task t = AsyncProcess();
            t.Wait();      
            Console.Read();           

        }

        async static Task AsyncProcess()
        {

            Task<string> task1 = GetInfoAsync("Task 1",3);        

                Task<string> task2 = GetInfoAsync("Task 2",5);
            string[] results = await Task.WhenAll(task1, task2);
            foreach (var item in results)
            {
                Console.WriteLine(item);
            }
        }

        async static Task<string> GetInfoAsync(string name,int second)
        {
            Console.WriteLine(string.Format("任务 {0} 开始。。。",name));

            await Task.Delay(TimeSpan.FromSeconds(second));
            //await Task.Run(() => Thread.Sleep(TimeSpan.FromSeconds(second));
            return string.Format(" Task {0} 正在运行在线程 ID={1}上。这个工作线程是否是线程池中的线程：{2}", name,
 Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
        }
    }
}