码迷,mamicode.com
首页 > Windows程序 > 详细

C# 异步编程

时间:2018-10-14 02:02:38      阅读:251      评论:0      收藏:0      [点我收藏+]

标签:char   await   watch   取消   eth   bubuko   star   inf   sed   

C# async/await特性可以创建b并使用异步方法

技术分享图片

技术分享图片

await表达式

await表达式指定了一个异步执行的任务

技术分享图片

 

取消一个异步操作

技术分享图片

 

CancellationTokenSource和CancellationToken来实现取消操作。

调用CancellationTokenSource的Cancel时,它本身不会执行取消操作。而是会将CancellationToken的IsCancellationRequest属性设置为true。

 class Program
    {
        static void Main(string[] args)
        {
         
            CancellationTokenSource cts = new CancellationTokenSource();
            CancellationToken token = cts.Token;

            MyClass my = new MyClass();
            Task t = my.RunAsync(token);

            Thread.Sleep(3000);
    //        cts.Cancel();
            //Console.ReadKey();
            t.Wait();

            Console.WriteLine("Was Cancelled:{0}", token.IsCancellationRequested);
            Console.ReadKey();
        }
    }



  class MyClass
    {
       
       

        internal async Task RunAsync(CancellationToken token)
        {
            if (token.IsCancellationRequested)
            {
                return;
            }
            await Task.Run(() => CycleMethod(token), token);
        }

        void CycleMethod(CancellationToken ct)
        {
            Console.WriteLine("Starting CycleMethod");
            const int Max = 5;
            for (int i = 0; i < Max; i++)
            {
                if (ct.IsCancellationRequested)
                {
                    return;
                }
     //           Thread.Sleep(1000);
                Console.WriteLine("   {0} of {1} iterations completed", i + 1, Max);
            }
        }
    }

 

在调用方法中同步等待任务

技术分享图片

技术分享图片

 class MydownLoadString
    {
        Stopwatch sw = new Stopwatch();

        public void DoRun()
        {
            const int LargeNumber = 60000000;
            sw.Start();
            Task<int> t1 = CountCharactersAsync(1, "http://www.microsoft.com");
            Task<int> t2 = CountCharactersAsync(2, "http://www.baidu.com");

            //Task<int>[] tasks = new Task<int>[] { t1, t2 };
            //Task.WaitAll(tasks);
            //Task.WaitAny(tasks);

            Console.WriteLine("Task 1: {0}Finished",t1.IsCompleted ? "" : "Not");
            Console.WriteLine("Task 2: {0}Finished", t2.IsCompleted ? "" : "Not");
            Console.ReadKey();
        }


        private async Task<int> CountCharactersAsync(int id, string site)
        {
            WebClient wc = new WebClient();
        //    Console.WriteLine("Starting call {0} : {1:4}ms", id, sw.Elapsed.TotalMilliseconds);
            string result = await wc.DownloadStringTaskAsync(new Uri(site));
            Console.WriteLine("  Call {0} completed:   {1:4} ms", id, sw.Elapsed.TotalMilliseconds);
            return result.Length;
        }

        private void CountToALargeNumber(int id, int value)
        {
            for (long i = 0; i < value; i++) ;
            Console.WriteLine("  End counting{0} :   {1:4} ms", id, sw.Elapsed.TotalMilliseconds);
        }
    }

技术分享图片

    //Task<int>[] tasks = new Task<int>[] { t1, t2 };
    //Task.WaitAll(tasks);
把上面两行注销掉
技术分享图片

 

//Task<int>[] tasks = new Task<int>[] { t1, t2 };
           
//Task.WaitAny(tasks);
把上面两行注销了

技术分享图片

 

 WaitAll方法,这时代码会停止并等待任务全部完成,然后继续执行

WaitAny方法 将终止并等待至少一个任务完成

技术分享图片

 

 
在异步方法中异步地等待任务
技术分享图片

 



 

C# 异步编程

标签:char   await   watch   取消   eth   bubuko   star   inf   sed   

原文地址:https://www.cnblogs.com/zquan/p/9784748.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!