异步的社会风气

阅读目录

 

新进级的程序猿也许对async、await用得非常多,却对前边的异步精晓吗少。本人正是此类,由此策画回想学习下异步的演化史。 

本文首即便回想async异步方式在此之前的异步,下篇小说再来注重拆解解析async异步模式。

APM

APM 异步编制程序模型,Asynchronous Programming Model

早在C#1的时候就有了APM。即使不是很驾驭,不过多少依旧见过的。便是那一个类是BeginXXX和EndXXX的方法,且BeginXXX再次来到值是IAsyncResult接口。

在专门的学业写APM示例早先咱们先付给意气风发段同步代码:

图片 1

//1、同步方法
private void button1_Click(object sender, EventArgs e)
{          
    Debug.WriteLine("【Debug】线程ID:" + Thread.CurrentThread.ManagedThreadId);

    var request = WebRequest.Create("https://github.com/");//为了更好的演示效果,我们使用网速比较慢的外网
    request.GetResponse();//发送请求    

    Debug.WriteLine("【Debug】线程ID:" + Thread.CurrentThread.ManagedThreadId);
    label1.Text = "执行完毕!";
}

图片 2

【表明】为了越来越好的示范异步效果,这里我们接收winform程序来做示范。(因为winform始终都急需UI线程渲染分界面,借使被UI线程占用则会冷俊不禁“假死”状态卡塔 尔(阿拉伯语:قطر‎

【效果图】

图片 3

看图获悉:

  • 大家在实施措施的时候页面现身了“假死”,拖不动了。
  • 大家看看打字与印刷结果,方法调用前和调用后线程ID都以9(也正是同贰个线程卡塔尔

上边大家再来演示对应的异步方法:(BeginGetResponse、EndGetResponse所谓的APM异步模型卡塔尔国

图片 4

private void button2_Click(object sender, EventArgs e)
{
    //1、APM 异步编程模型,Asynchronous Programming Model
    //C#1[基于IAsyncResult接口实现BeginXXX和EndXXX的方法]             
    Debug.WriteLine("【Debug】主线程ID:" + Thread.CurrentThread.ManagedThreadId);

    var request = WebRequest.Create("https://github.com/");
    request.BeginGetResponse(new AsyncCallback(t =>//执行完成后的回调
    {
        var response = request.EndGetResponse(t);
        var stream = response.GetResponseStream();//获取返回数据流 

        using (StreamReader reader = new StreamReader(stream))
        {
            StringBuilder sb = new StringBuilder();
            while (!reader.EndOfStream)
            {
                var content = reader.ReadLine();
                sb.Append(content);
            }
            Debug.WriteLine("【Debug】" + sb.ToString().Trim().Substring(0, 100) + "...");//只取返回内容的前100个字符 
            Debug.WriteLine("【Debug】异步线程ID:" + Thread.CurrentThread.ManagedThreadId);
            label1.Invoke((Action)(() => { label1.Text = "执行完毕!"; }));//这里跨线程访问UI需要做处理
        }
    }), null);

    Debug.WriteLine("【Debug】主线程ID:" + Thread.CurrentThread.ManagedThreadId); 
}

图片 5

【效果图】

 图片 6

看图得到消息:

  • 启用异步方法并不曾是UI分界面卡死
  • 异步方法运转了其它二个ID为12的线程

地方代码施行顺序:

图片 7

眼前我们说过,APM的BebinXXX必需再次回到IAsyncResult接口。那么接下去大家拆解解析IAsyncResult接口:

首先大家看:

图片 8

真的再次回到的是IAsyncResult接口。这IAsyncResult到底长的如何体统?:

图片 9

并从未想像中的那么复杂嘛。我们是还是不是能够品尝那得以达成那一个接口,然后呈现自己的异步方法呢?

首先定叁个类MyWebRequest,然后继续IAsyncResult:(上面是着力的伪代码落成卡塔 尔(英语:State of Qatar)

图片 10

public class MyWebRequest : IAsyncResult
{
    public object AsyncState
    {
        get { throw new NotImplementedException(); }
    }

    public WaitHandle AsyncWaitHandle
    {
        get { throw new NotImplementedException(); }
    }

    public bool CompletedSynchronously
    {
        get { throw new NotImplementedException(); }
    }

    public bool IsCompleted
    {
        get { throw new NotImplementedException(); }
    }
}

图片 11

如此自然是不可能用的,最少也得有个存回调函数的性子吧,下边我们多少退换下:

图片 12

接下来大家得以自定义APM异步模型了:(成对的Begin、End卡塔 尔(英语:State of Qatar)

图片 13

public IAsyncResult MyBeginXX(AsyncCallback callback)
{
    var asyncResult = new MyWebRequest(callback, null);
    var request = WebRequest.Create("https://github.com/");
    new Thread(() =>  //重新启用一个线程
    {
        using (StreamReader sr = new StreamReader(request.GetResponse().GetResponseStream()))
        {
            var str = sr.ReadToEnd();
            asyncResult.SetComplete(str);//设置异步结果
        }

    }).Start();
    return asyncResult;//返回一个IAsyncResult
}

public string MyEndXX(IAsyncResult asyncResult)
{
    MyWebRequest result = asyncResult as MyWebRequest;
    return result.Result;
}

图片 14

调用如下:

图片 15

 private void button4_Click(object sender, EventArgs e)
 {
     Debug.WriteLine("【Debug】主线程ID:" + Thread.CurrentThread.ManagedThreadId);
     MyBeginXX(new AsyncCallback(t =>
     {
         var result = MyEndXX(t);
         Debug.WriteLine("【Debug】" + result.Trim().Substring(0, 100) + "...");
         Debug.WriteLine("【Debug】异步线程ID:" + Thread.CurrentThread.ManagedThreadId);
     }));
     Debug.WriteLine("【Debug】主线程ID:" + Thread.CurrentThread.ManagedThreadId);
 }

图片 16

效果图:

图片 17

作者们看到本身达成的机能基本上和类别提供的大都。

  • 启用异步方法并不曾是UI分界面卡死
  • 异步方法运转了其余一个ID为11的线程

【总结】

村办感到APM异步方式就是启用其它一个线程奉行耗费时间任务,然后通过回调函数实践后续操作。

APM还足以因而任何形式获取值,如:

while (!asyncResult.IsCompleted)//循环,直到异步执行完成 (轮询方式)
{
    Thread.Sleep(100);
}
var stream2 = request.EndGetResponse(asyncResult).GetResponseStream();

asyncResult.AsyncWaitHandle.WaitOne();//阻止线程,直到异步完成 (阻塞等待)
var stream2 = request.EndGetResponse(asyncResult).GetResponseStream();

 

补充:假如是平常方法,大家也得以通过委托异步:(BeginInvoke、EndInvoke卡塔尔

图片 18

 public void MyAction()
 {
     var func = new Func<string, string>(t =>
     {
         Thread.Sleep(2000);
         return "name:" + t + DateTime.Now.ToString();
     });

     var asyncResult = func.BeginInvoke("张三", t =>
     {
         string str = func.EndInvoke(t);
         Debug.WriteLine(str);
     }, null); 
 }

图片 19

EAP

EAP 基于事件的异步形式,Event-based Asynchronous Pattern

此方式在C#2的时候光临。

先来看个EAP的例证:

图片 20

 private void button3_Click(object sender, EventArgs e)
 {            
     Debug.WriteLine("【Debug】主线程ID:" + Thread.CurrentThread.ManagedThreadId);

     BackgroundWorker worker = new BackgroundWorker();
     worker.DoWork += new DoWorkEventHandler((s1, s2) =>
     {
         Thread.Sleep(2000);
         Debug.WriteLine("【Debug】异步线程ID:" + Thread.CurrentThread.ManagedThreadId);
     });//注册事件来实现异步
     worker.RunWorkerAsync(this);
     Debug.WriteLine("【Debug】主线程ID:" + Thread.CurrentThread.ManagedThreadId);
 }

图片 21

 

【效果图】(相近不会梗塞UI分界面卡塔尔

图片 22

【特征】

  • 透过事件的艺术注册回调函数
  • 经过 XXXAsync方法来进行异步调用

事例很简短,可是和APM形式比较,是或不是不曾那么显然透明。为何能够那样完成?事件的登记是在干嘛?为何实施RunWorkerAsync会触发注册的函数?

认为温馨又想多了…

大家试着反编写翻译看看源码:

图片 23

 只想说,这么玩,风趣吗?

TAP

TAP 基于任务的异步方式,Task-based Asynchronous Pattern

到目前截至,大家以为下边包车型大巴APM、EAP异步形式好用吗?好像从没察觉怎么难点。再稳重思考…倘使我们有八个异步方法供给按前后相继顺序推行,而且要求(在主进度)获得全体重返值。

第一定义三个委托:

图片 24

public Func<string, string> func1()
{
    return new Func<string, string>(t =>
    {
        Thread.Sleep(2000);
        return "name:" + t;
    });
}
public Func<string, string> func2()
{
    return new Func<string, string>(t =>
    {
        Thread.Sleep(2000);
        return "age:" + t;
    });
}
public Func<string, string> func3()
{
    return new Func<string, string>(t =>
    {
        Thread.Sleep(2000);
        return "sex:" + t;
    });
}

图片 25

接下来遵照一定顺序实行:

图片 26

public void MyAction()
{
    string str1 = string.Empty, str2 = string.Empty, str3 = string.Empty;
    IAsyncResult asyncResult1 = null, asyncResult2 = null, asyncResult3 = null;
    asyncResult1 = func1().BeginInvoke("张三", t =>
    {
        str1 = func1().EndInvoke(t);
        Debug.WriteLine("【Debug】异步线程ID:" + Thread.CurrentThread.ManagedThreadId);
        asyncResult2 = func2().BeginInvoke("26", a =>
        {
            str2 = func2().EndInvoke(a);
            Debug.WriteLine("【Debug】异步线程ID:" + Thread.CurrentThread.ManagedThreadId);
            asyncResult3 = func3().BeginInvoke("男", s =>
            {
                str3 = func3().EndInvoke(s);
                Debug.WriteLine("【Debug】异步线程ID:" + Thread.CurrentThread.ManagedThreadId);
            }, null);
        }, null);
    }, null);

    asyncResult1.AsyncWaitHandle.WaitOne();
    asyncResult2.AsyncWaitHandle.WaitOne();
    asyncResult3.AsyncWaitHandle.WaitOne();
    Debug.WriteLine(str1 + str2 + str3);
} 

图片 27

而外难看、难读一点像样也没怎么 。可是实乃这么呢?

图片 28

asyncResult2是null?
有鉴于此在达成第3个异步操作在此以前未曾对asyncResult2进行赋值,asyncResult2施行异步等待的时候报那个。那么那样大家就无法调控多个异步函数,遵照一定顺序实践到位后再获得再次回到值。(理论上或许有其它方法的,只是会然代码越发千头万绪卡塔 尔(英语:State of Qatar)

 

是的,现在该我们的TAP登台了。

图片 29

只需求调用Task类的静态方法Run,就可以轻巧使用异步。

获取重返值:

图片 30

var task1 = Task<string>.Run(() =>
{
    Thread.Sleep(1500);
    Console.WriteLine("【Debug】task1 线程ID:" + Thread.CurrentThread.ManagedThreadId);
    return "张三";
});
//其他逻辑            
task1.Wait();
var value = task1.Result;//获取返回值
Console.WriteLine("【Debug】主 线程ID:" + Thread.CurrentThread.ManagedThreadId);

图片 31

后日大家管理地方多个异步按序试行:

图片 32

Console.WriteLine("【Debug】主 线程ID:" + Thread.CurrentThread.ManagedThreadId);
string str1 = string.Empty, str2 = string.Empty, str3 = string.Empty;
var task1 = Task.Run(() =>
{
    Thread.Sleep(500);
    str1 = "姓名:张三,";
    Console.WriteLine("【Debug】task1 线程ID:" + Thread.CurrentThread.ManagedThreadId);
}).ContinueWith(t =>
{
    Thread.Sleep(500);
    str2 = "年龄:25,";
    Console.WriteLine("【Debug】task2 线程ID:" + Thread.CurrentThread.ManagedThreadId);
}).ContinueWith(t =>
{
    Thread.Sleep(500);
    str3 = "爱好:妹子";
    Console.WriteLine("【Debug】task3 线程ID:" + Thread.CurrentThread.ManagedThreadId);
});

Thread.Sleep(2500);//其他逻辑代码

task1.Wait();

Debug.WriteLine(str1 + str2 + str3);
Console.WriteLine("【Debug】主 线程ID:" + Thread.CurrentThread.ManagedThreadId);

图片 33

[效果图]

图片 34

我们见到,结果都获得了,且是异步按序施行的。且代码的逻辑思路拾贰分清楚。如果你感触还不是非常的大,那么您现象后生可畏经是九14个异步方法须求异步按序执行吗?用APM的异步回调,那最少也得异步回调嵌套一百次。那代码的复杂度简单来讲。

 

延长考虑

  • WaitOne完结等待的规律

  • 异步为何会升高质量

  • 线程的施用数据和CPU的使用率有必然的牵连呢

 

标题1:WaitOne完毕等待的原理

在此以前,我们先来大致的询问下八线程功率信号调节AutoResetEvent类。

var _asyncWaitHandle = new AutoResetEvent(false);
_asyncWaitHandle.WaitOne();

此代码会在 WaitOne 之处会一向等待下去。除非有别的一个线程施行 AutoReset伊芙nt 的set方法。

var _asyncWaitHandle = new AutoResetEvent(false);
_asyncWaitHandle.Set();
_asyncWaitHandle.WaitOne();

这么,到了 WaitOne 就能够直接施行下去。未有有别的等待。

现今大家对APM 异步编制程序模型中的 WaitOne 等待是否领略了点什么吧。大家回头来兑现从前自定义异步方法的异步等待。

图片 35

public class MyWebRequest : IAsyncResult
{
    //异步回调函数(委托)
    private AsyncCallback _asyncCallback;
    private AutoResetEvent _asyncWaitHandle;
    public MyWebRequest(AsyncCallback asyncCallback, object state)
    {
        _asyncCallback = asyncCallback;
        _asyncWaitHandle = new AutoResetEvent(false);
    }
    //设置结果
    public void SetComplete(string result)
    {
        Result = result;
        IsCompleted = true;
        _asyncWaitHandle.Set();
        if (_asyncCallback != null)
        {
            _asyncCallback(this);
        }
    }
    //异步请求返回值
    public string Result { get; set; }
    //获取用户定义的对象,它限定或包含关于异步操作的信息。
    public object AsyncState
    {
        get { throw new NotImplementedException(); }
    }
    // 获取用于等待异步操作完成的 System.Threading.WaitHandle。
    public WaitHandle AsyncWaitHandle
    {
        //get { throw new NotImplementedException(); }

        get { return _asyncWaitHandle; }
    }
    //获取一个值,该值指示异步操作是否同步完成。
    public bool CompletedSynchronously
    {
        get { throw new NotImplementedException(); }
    }
    //获取一个值,该值指示异步操作是否已完成。
    public bool IsCompleted
    {
        get;
        private set;
    }
}

图片 36

辛丑革命代码便是新增的异步等待。

【实施步骤】

图片 37

 

题目2:异步为啥会晋级质量

比方同步代码:

Thread.Sleep(10000);//假设这是个访问数据库的方法
Thread.Sleep(10000);//假设这是个访问FQ网站的方法

本条代码需求20秒。

如假如异步:

图片 38

var task = Task.Run(() =>
{
    Thread.Sleep(10000);//假设这是个访问数据库的方法
});
Thread.Sleep(10000);//假设这是个访问FQ网站的方法
task.Wait();

图片 39

这么就假若10秒了。那样就省去了10秒。

如果是:

var task = Task.Run(() =>
{
    Thread.Sleep(10000);//假设这是个访问数据库的方法
}); 
task.Wait();

异步执行中间未有耗费时间的代码那么那样的异步将是没风乐趣的。

或者:

图片 40

var task = Task.Run(() =>
{
    Thread.Sleep(10000);//假设这是个访问数据库的方法
}); 
task.Wait();
Thread.Sleep(10000);//假设这是个访问FQ网站的方法

图片 41

把耗费时间职务放在异步等待后,那那样的代码也是不会有总体性提高的。

再有风流浪漫种情状:

假假诺单核CPU实行高密集运算操作,那么异步也是从未有过意义的。(因为运算是至极耗CPU,而互联网须要等待不耗CPU)

 

标题3:线程的应用数据和CPU的使用率有自然的联系吗

答案是或不是。

如故拿单核做假若。

情况1:

图片 42

long num = 0;
while (true)
{
    num += new Random().Next(-100,100);
    //Thread.Sleep(100);
}

图片 43

单核下,大家只运转叁个线程,就足以让您CPU爆满。

图片 44图片 45

开发银行四遍,八进度CPU基本满员。

情况2:

图片 46

图片 47

风度翩翩千三个线程,而CPU的使用率竟然是0。由此,大家得到了以前的结论,线程的应用数据和CPU的使用率未有一定的牵连。

虽说这么,但是也必须要要限制的拉开线程。因为:

  • 展开三个新的线程的进程是相比功耗源的。(然而使用线程池,来下滑开启新线程所花销的能源卡塔尔
  • 十二线程的切换也是需求时日的。
  • 每一种线程占用了一定的内部存款和储蓄器保存线程上下文消息。

 

demo:http://pan.baidu.com/s/1slOxgnF

相关文章