365足球网站【转】C#异步的世界【上】[转]C#异步的社会风气【上】,

【转】C#异步的世界【上】

[转]C#异步的社会风气【上】,

初进阶的程序员可能针对async、await用得较多,却对之前的异步了解非常少。本人就是此类,因此打算回顾上下异步的进化史。 

读目录

  • APM
  • EAP
  • TAP
  • 延伸思考

新进阶的程序员可能针对async、await用得比较多,却对前面的异步了解非常少。本人就是是此类,因此打算回顾上下异步的进化史。 

本文主要是回顾async异步模式之前的异步,下篇文章更来第一分析async异步模式。

本文主要是回顾async异步模式之前的异步,下篇文章更来要分析async异步模式。

APM

APM 异步编程模型,Asynchronous Programming Model

早在C#1底上就是起矣APM。虽然不是好熟悉,但是有些要展现了之。就是那些看似是BeginXXX和EndXXX的章程,且BeginXXX返回值是IAsyncResult接口。

当业内写APM示例之前我们事先为来同截共代码:

365足球网站 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 = "执行完毕!";
}

365足球网站 2

【说明】为了重新好之演示异步效果,这里我们下winform程序来开示范。(因为winform始终犹亟待UI线程渲染界面,如果被UI线程占用则会面世“假死”状态)

【效果图】

365足球网站 3

关押图得知:

  • 咱们于推行方的早晚页面出现了“假死”,拖不动了。
  • 咱看出打印结果,方法调用前与调用后线程ID都是9(也就是是跟一个线程)

下我们再来演示对应的异步方法:(BeginGetResponse、EndGetResponse所谓的APM异步模型)

365足球网站 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); 
}

365足球网站 5

【效果图】

 365足球网站 6

在押图得知:

  • 启用异步方法并不曾是UI界面卡死
  • 异步方法启动了另外一个ID为12之线程

地方代码执行顺序:

365足球网站 7

前方我们说过,APM的BebinXXX必须回到IAsyncResult接口。那么接下我们解析IAsyncResult接口:

第一我们看:

365足球网站 8

当真返回的凡IAsyncResult接口。那IAsyncResult到底长的呦法?:

365足球网站 9

并没设想着的那么复杂嘛。我们是否好尝试这贯彻之接口,然后显示自己之异步方法吗?

第一得一个类MyWebRequest,然后继续IAsyncResult:(下面是基本的伪代码实现)

365足球网站 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(); }
    }
}

365足球网站 11

这么必然是无克就此之,起码也得生只存回调函数的特性吧,下面我们小改造下:

365足球网站 12

接下来我们得以于定义APM异步模型了:(成对的Begin、End)

365足球网站 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;
}

365足球网站 14

调用如下:

365足球网站 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);
 }

365足球网站 16

效果图:

365足球网站 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)

365足球网站 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); 
 }

365足球网站 19

APM

APM 异步编程模型,Asynchronous Programming Model

早在C#1底时刻即便来了APM。虽然不是甚熟稔,但是有些还是表现了的。就是那些看似是BeginXXX和EndXXX的法门,且BeginXXX返回值是IAsyncResult接口。

当专业写APM示例之前我们先行为来一致段落同代码

//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 = "执行完毕!";
}

【说明】为了重新好之以身作则异步效果,这里我们使用winform程序来举行示范。(因为winform始终都要UI线程渲染界面,如果为UI线程占用则会冒出“假死”状态)

【效果图】

365足球网站 20

看图得知:

  • 咱以尽方式的时刻页面出现了“假死”,拖不动了。
  • 咱们看到打印结果,方法调用前以及调用后线程ID都是9(也便是同一个线程)

脚我们更来演示对应的异步方法:(BeginGetResponse、EndGetResponse所谓的APM异步模型)

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); 
}

【效果图】

 365足球网站 21

看图得知:

  • 启用异步方法并没有是UI界面卡死
  • 异步方法启动了另外一个ID为12的线程

上面代码执行顺序:

365足球网站 22

眼前我们说了,APM的BebinXXX必须返回IAsyncResult接口。那么连下我们解析IAsyncResult接口:

第一我们看:

365足球网站 23

实在返回的是IAsyncResult接口。那IAsyncResult到底长的呀体统?:

365足球网站 24

并没想象中之那复杂嘛。我们是不是可以品味这贯彻者接口,然后显示自己之异步方法呢?

第一得一个类MyWebRequest,然后继续IAsyncResult:(下面是基本的伪代码实现)

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(); }
    }
}

这样自然是匪可知因此的,起码也得起只存回调函数的性能吧,下面我们小改造下:

365足球网站 25

下一场我们好自定义APM异步模型了:(成对的Begin、End)

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;
}

调用如下:

 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);
 }

效果图:

365足球网站 26

咱来看好实现的职能基本上与系提供的大都。

  • 启用异步方法并没是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)

 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); 
 }

EAP

EAP 基于事件之异步模式,Event-based Asynchronous Pattern

是模式于C#2底下光顾。

先来拘禁个EAP的例证:

365足球网站 27

 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);
 }

365足球网站 28

 

【效果图】(同样未会见阻塞UI界面)

365足球网站 29

【特征】

  • 由此波之计注册回调函数
  • 经过 XXXAsync方法来执行异步调用

事例很简短,但是和APM模式相比,是匪是不曾那么清楚透明。为什么可以如此实现?事件的登记是于关系嘛?为什么执行RunWorkerAsync会触发注册的函数?

感觉自己同时想多矣…

咱们尝试着倒编译看看源码:

365足球网站 30

 只想说,这么玩,有意思吗?

EAP

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

这个模式于C#2之时段光顾。

先期来拘禁个EAP的事例:

 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);
 }

 

【效果图】(同样无会见阻塞UI界面)

365足球网站 31

【特征】

  • 透过波之道注册回调函数
  • 由此 XXXAsync方法来实行异步调用

事例很简单,但是与APM模式相比,是免是绝非那鲜明透明。为什么可以这样实现?事件之注册是于关系嘛?为什么执行RunWorkerAsync会触发注册的函数?

感觉到好而想多了…

咱俩摸索着倒编译看看源码:

365足球网站 32

 只想说,这么玩,有意思啊?

TAP

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

至目前为止,我们当上面的APM、EAP异步模式好用为?好像没察觉什么问题。再精心想想…如果我们出多独异步方法要按先后顺序执行,并且要(在主进程)得到有返回值。

率先定义三只委托:

365足球网站 33

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;
    });
}

365足球网站 34

接下来以一定顺序执行:

365足球网站 35

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);
} 

365足球网站 36

除了难看、难读一些近乎也尚无什么 。不过真正是这般啊?

365足球网站 37

asyncResult2是null?
由此可见在形成第一独异步操作前没有对准asyncResult2进行赋值,asyncResult2执行异步等待的时刻报那个。那么这样我们就算无法控制三独异步函数,按照一定顺序执行到位后更将到回值。(理论及或者产生其它办法之,只是会然代码更加扑朔迷离)

 

科学,现在该我们的TAP登场了。

365足球网站 38

独自需要调用Task类的静态方法Run,即可轻松使用异步。

得返回值:

365足球网站 39

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);

365足球网站 40

兹咱们处理者多单异步按次序执行:

365足球网站 41

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);

365足球网站 42

[效果图]

365足球网站 43

咱们看看,结果尚且落了,且是异步按顺序执行之。且代码的逻辑思路十分清晰。如果你感触还未是格外怪,那么您现象而是100独异步方法要异步按次执行吗?用APM的异步回调,那至少也得异步回调嵌套100坏。那代码的复杂度可想而知。

 

TAP

TAP 基于任务之异步模式,Task-based Asynchronous Pattern

及目前为止,我们觉得上面的APM、EAP异步模式好用为?好像没有发觉什么问题。再仔细想想…如果我们有多个异步方法要遵循先后顺序执行,并且用(在主进程)得到有返回值。

率先定义三独委托:

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;
    });
}

接下来以一定顺序执行:

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);
} 

除了难看、难读一些近乎也远非什么 。不过真的是这般为?

365足球网站 44

asyncResult2是null?
有鉴于此在做到第一个异步操作前未曾针对asyncResult2进行赋值,asyncResult2执行异步等待的时节报好。那么这么我们就是无法控制三个异步函数,按照一定顺序执行就后重新以到回值。(理论及或产生其它方的,只是会然代码更加扑朔迷离)

 

正确,现在欠我们的TAP登场了。

365足球网站 45

唯有待调用Task类的静态方法Run,即可轻松使用异步。

得返回值:

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);

当今咱们处理方面多单异步按次序执行:

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);

[效果图]

365足球网站 46

咱看,结果尚且取了,且是异步按程序执行的。且代码的逻辑思路好鲜明。如果您感触还不是坏十分,那么您现象而是100独异步方法需要异步按次执行也?用APM的异步回调,那至少为得异步回调嵌套100不良。那代码的复杂度可想而知。

 

延思考

  • WaitOne就等的原理

  • 异步为什么会提升性能

  • 线程的动数据及CPU的使用率有肯定的联络也

 

题材1:WaitOne完成等的法则

在此之前,我们事先来大概的刺探下多线程信号控制AutoResetEvent类。

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

此代码会在 WaitOne 的地方会面一直等下。除非有另外一个线程执行 AutoResetEvent 的set方法。

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

这样,到了 WaitOne 就可以直接执行下。没有产生其它等待。

现咱们针对APM 异步编程模型中的 WaitOne 等待是休是清楚了接触什么吗。我们回头来兑现之前由定义异步方法的异步等待。

365足球网站 47

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;
    }
}

365足球网站 48

赤代码就是骤增的异步等待。

【执行步骤】

365足球网站 49

 

题材2:异步为什么会升级性

遵照同代码:

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

斯代码用20秒。

假使是异步:

365足球网站 50

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

365足球网站 51

诸如此类就设10秒了。这样就是省去了10秒。

如果是:

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

异步执行中没有耗时的代码那么这样的异步将凡未曾意思的。

或者:

365足球网站 52

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

365足球网站 53

把耗时任务在异步等待后,那这样的代码也是免见面生出性能提升的。

再有同种状态:

使是单核CPU进行高密集运算操作,那么异步也是没有意思之。(因为运算是死耗CPU,而网要等待不耗CPU)

 

题目3:线程的使用数据及CPU的使用率有早晚之关联也

答案是否。

或用就核做要。

情况1:

365足球网站 54

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

365足球网站 55

单核下,我们才启动一个线程,就可于你CPU爆满。

365足球网站 56365足球网站 57

开行八不好,八进程CPU基本满员。

情况2:

365足球网站 58

365足球网站 59

一千多个线程,而CPU的使用率还是0。由此,我们收获了事先的结论,线程的下数据及CPU的使用率没有定之联络。

虽然这样,但是也非克毫无节制的启线程。因为:

  • 被一个新的线程的经过是比耗资源的。(可是使用线程池,来降低开启新线程所耗费的资源)
  • 大多线程的切换为是内需时间的。
  • 每个线程占用了定的内存保存线程上下文信息。

 

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

http://www.bkjia.com/C\_jc/1202634.htmlwww.bkjia.comtruehttp://www.bkjia.com/C\_jc/1202634.htmlTechArticle\[转\]C\#异步的世界【上】, 阅读目录 APM EAP TAP
延伸思考
新进阶的程序员可能对async、await用得较多,却对前面的异步了解很少。本人就是…

延长思考

  • WaitOne就等的原理

  • 异步为什么会提升性能

  • 线程的运用数据和CPU的使用率有肯定的联系呢

 

问题1:WaitOne完成等的法则

在此之前,我们事先来大概的刺探下多线程信号控制AutoResetEvent类。

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

本条代码会当 WaitOne 的地方会面一直等下。除非有另外一个线程执行 AutoResetEvent 的set方法。

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

这么,到了 WaitOne 就好直接执行下。没有发其它等待。

现咱们针对APM 异步编程模型中的 WaitOne 等待是不是知了碰什么吗。我们回头来实现之前起定义异步方法的异步等待。

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;
    }
}

辛亥革命代码就是骤增的异步等待。

【执行步骤】

365足球网站 60

 

问题2:异步为什么会提升性

准同代码:

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

本条代码用20秒。

假使是异步:

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

诸如此类就假设10秒了。这样即便节约了10秒。

如果是:

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

异步执行中没有耗时的代码那么这么的异步将凡没意思的。

或者:

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

管耗时任务在异步等待后,那这样的代码也是无会见来总体性提升的。

再有雷同栽情况:

如若是单核CPU进行高密集运算操作,那么异步也是从未有过意义之。(因为运算是老大耗CPU,而网络要等待不耗CPU)

 

问题3:线程的施用数据及CPU的使用率有一定的联络吗

答案是否。

或者拿就核做使。

情况1:

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

单核下,我们只是启动一个线程,就可吃您CPU爆满。

365足球网站 61365足球网站 62

开行八浅,八历程CPU基本满员。

情况2:

365足球网站 63

365足球网站 64

一千多只线程,而CPU的使用率还是0。由此,我们沾了前面的定论,线程的施用数据与CPU的使用率没有定之联络。

虽然这么,但是也未克不要节制的展线程。因为:

  • 展一个新的线程的历程是于耗资源的。(可是使用线程池,来降低开启新线程所消耗的资源)
  • 多线程的切换为是需要时之。
  • 每个线程占用了定之内存保存线程上下文信息。

 

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

本文就联手至索引目录:《C#基础知识巩固》

对于异步编程了解不很,文中极有或多处错误描述和看法。

谢谢广大园友的指正。

对相互讨论的目的,绝无想使误导大家之意。

 

【推荐】

http://www.cnblogs.com/wisdomqq/archive/2012/03/26/2412349.html

相关文章