a亚洲精品_精品国产91乱码一区二区三区_亚洲精品在线免费观看视频_欧美日韩亚洲国产综合_久久久久久久久久久成人_在线区

首頁 > 編程 > C# > 正文

.NET中的async和await關鍵字使用及Task異步調用實例

2020-01-24 02:39:54
字體:
來源:轉載
供稿:網友

其實早在.NET 4.5的時候M$就在.NET中引入了async和await關鍵字(VB為Async和Await)來簡化異步調用的編程模式。我也早就體驗過了,現在寫一篇日志來記錄一下順便湊日志數量(以后面試之前可以用這個“復習”一下)。

(一)傳統的異步調用

在比較“古老”的C#程序中經常可以看到IAsyncResult、BeginInvoke之類的異步調用“蹤跡”。先來簡單的復習一下吧。

假如我們有一個方法生成字符串,而生成這個字符串需要10秒中的時間:

復制代碼 代碼如下:

public class WasteTimeObject
{
    public string GetSlowString(int begin, int length)
    {
        StringBuilder sb = new StringBuilder();

        for (int i = begin; i < begin + length; i++)
        {
            sb.Append(WasteTime(i) + " ");
        }

        return sb.ToString();
    }

    private string WasteTime(int current)
    {
        System.Threading.Thread.Sleep(1000);
        return current.ToString();
    }
}

我們再做一個窗口,用來請求這個方法并把字符串顯示到文本框中。使用同步調用肯定會把UI線程阻塞掉,要想不把UI阻塞掉就要另起一個線程了。基本的步驟如下:

創建一個異步調用的委托:

復制代碼 代碼如下:

public delegate string GetSlowStringDelegate(int begin, int length);

然后呢,再異步調用這個委托:

復制代碼 代碼如下:

private void button1_Click(object sender, EventArgs e)
{
    WasteTimeObject ad = new WasteTimeObject();
    GetSlowStringDelegate d = ad.GetSlowString;

    textBox1.Text = "Requesting string, please wait...";

    IAsyncResult ar = d.BeginInvoke(1, 10, TaskComplete, d);
}

這里的BeginInvoke會在原來的基礎上再附加兩個參數:表示執行完畢后的回調方法AsyncCallBack,最后一個參數可以是任何對象,以便從回調方法中訪問它。不過一般情況都是傳遞的委托實例,以便獲取調用的結果。

當然我們也可以不用回調方法,這樣就只好不斷地循環查詢是否執行完成了。

然后我們就要編寫AsyncCallBack這個回調方法了,它接受一個IAsyncResult類型的對象表示異步調用的結果:

復制代碼 代碼如下:

private void TaskComplete(IAsyncResult ar)
{
    if (ar == null) return;
    GetSlowStringDelegate d = ar.AsyncState as GetSlowStringDelegate;
    if (d == null) throw new Exception("Invalue object type");
    string result = d.EndInvoke(ar);
    this.Invoke(new Action(() => UpdateTextResult(result)));
}

調用委托實例的EndInvoke方法并傳入IAsyncResult類型的對象用以獲取GetSlowString的返回結果。

回調方法是委托線程調用的,因此它不能直接訪問UI,所以我們使用窗體的Invoke方法在主線程中顯示結果。如果委托方法拋出異常,將會在EndInvoke時拋出。

(二)使用Task類型

可以看到使用傳統的辦法編寫異步調用很麻煩,特別是如果這種調用很多,那么我們的程序就會變成很復雜,邏輯很亂。

.NET 4.5提供的新的異步變成模式就很好地解決了這個問題(其實本質上應該是.NET自動實現了很多操作),使編寫異步代碼和同步調用一樣邏輯清晰。

首先來看看微軟的例子:

復制代碼 代碼如下:

private async Task SumPageSizesAsync()
{
    // To use the HttpClient type in desktop apps, you must include a using directive and add a
    // reference for the System.Net.Http namespace.
    HttpClient client = new HttpClient();

    // Equivalently, now that you see how it works, you can write the same thing in a single line.
    byte[] urlContents = await client.GetByteArrayAsync(url);
    // . . .
}

可以看出,使用await關鍵字后,.NET會自動把返回結果包裝在一個Task類型的對象中。對于這個示例,方法是沒有返回結果的。而對有返回結果的方法,就要使用Task<T>了:

復制代碼 代碼如下:

public async Task<string> WaitAsynchronouslyAsync()
{
    await Task.Delay(10000);
    return "Finished";
}

總而言之,使用await表達式時,控制會返回到調用此方法的線程中;在await等待的方法執行完畢后,控制會自動返回到下面的語句中。發生異常時,異常會在await表達式中拋出。

對于我們這個例子,我們編寫的代碼如下:

復制代碼 代碼如下:

private async void button1_Click(object sender, EventArgs e)
{
    textBox1.Text = "Requesting string, please wait...";

    WasteTimeObject ad = new WasteTimeObject();

    string result = await Task.Run(() => ad.GetSlowString(1, 10));

    //Update UI to display the result
    textBox1.Text = result;
}

我們使用Task類新建一個工作線程并執行。當然我們也可以像M$給的例子那樣改造一下GetSlowString,這樣就不需要加上Task.Run了。(基本上,這種方法都會以Async后綴結尾。)

如何?原來的:創建異步委托→回調一氣呵成。另外還有一點,await下面的語句是由主線程調用的,不是由新的線程調用,所以我們可以直接訪問UI。

(三)取消執行和顯示進度

最后一個要記錄的,就是如何給異步調用添加進度條,并能讓用戶取消操作。界面就是下面這樣:

使用最終完成的代碼來說明吧。首先改造GetSlowString方法,使之支持取消和匯報進度:

復制代碼 代碼如下:

public string GetSlowString(int begin, int length, IProgress<int> progress, CancellationToken cancel)
{
    StringBuilder sb = new StringBuilder();

    for (int i = begin; i < begin + length; i++)
    {
        sb.Append(WasteTime(i) + " ");

        cancel.ThrowIfCancellationRequested();

        if (progress != null)
            progress.Report((int)((double)(i - begin + 1) * 100 / length));
    }

    return sb.ToString();
}

IProgress<T>類型的對象有一個Report方法,執行這個方法實際上會調用自定義的更新進度的方法,這個方法(使用委托或匿名方法皆可)是在生成Progress<T>對象的時候指定的:

復制代碼 代碼如下:

IProgress<int> progress = new Progress<int>((progressValue) => { progressBar1.Value = progressValue; });

神奇的是,這個方法是由主線程調用的,如果不是這樣,它就不能更新我們界面上的控件。所以說微軟提供的新機制幫我們簡化了很多工作。

CancellationToken用于指定該方法“綁定”的取消上下文,如果這個對象執行過Cancel方法(用戶點擊了Cancel按鈕),那么訪問ThrowIfCancellationRequested時就會拋出OperationCanceledException類型的異常。這種機制的靈活性在于中止執行的位置是可以自行確定的,不會出現取消時自己都不知道執行到哪行代碼的情況。

總而言之,單擊request按鈕的代碼我們修改如下:

復制代碼 代碼如下:

private async void button1_Click(object sender, EventArgs e)
{

    cancelSource = new CancellationTokenSource();
    IProgress<int> progress = new Progress<int>((progressValue) => { progressBar1.Value = progressValue; });

    textBox1.Text = "Requesting string, please wait...";
    button1.Enabled = false; button2.Enabled = true;

    WasteTimeObject ad = new WasteTimeObject();

    try
    {
        string result = await Task.Run(() => ad.GetSlowString(1, 10, progress, cancelSource.Token),
            cancelSource.Token);
        //Update UI to display the result
        textBox1.Text = result;
        button2.Enabled = false;  //Disable cancel button
    }
    catch (OperationCanceledException)
    {
        textBox1.Text = "You canceled the operation.";
    }

}

取消按鈕的代碼就很簡單了:

復制代碼 代碼如下:

private void button2_Click(object sender, EventArgs e)
{
    if (cancelSource != null) cancelSource.Cancel();
    button2.Enabled = false;
}

至此,Task機制的初步體驗就到此完成。以后有機會在研究下更高階的內容吧。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 国产成人精品一区二区三区视频 | 国产一区二区在线播放 | 国产一区二区三区在线免费观看 | 国内精品视频 | 久草免费福利 | 热久久久久 | av大片在线 | 九九色综合 | 久久精品国产99久久久 | 性色爽爱 | 狠狠操夜夜操天天操 | 欧美一区二区三区免费在线观看 | 一区二区在线免费观看 | 国产欧美日韩综合精品一区二区 | 91麻豆精品国产91久久久资源速度 | 亚洲爱| 久久99精品国产99久久6男男 | 色综合99 | 欧美日韩一区二区视频在线观看 | 粉嫩高清一区二区三区 | 亚洲免费小视频 | 91久久精品一区二区别 | 一区二区视频 | 中文字幕加勒比 | 日本aⅴ免费视频一区二区三区 | 欧美激情欧美激情在线五月 | 久久精品久久久 | 国产精品成人3p一区二区三区 | 欧美成人福利 | 激情五月婷婷在线 | 黄篇网址| 美女久久 | 精品91 | 国产精品1区2区3区 国产成人精品一区二区三区四区 | 午夜影院在线观看视频 | 国产九九精品 | 国产精品99久久久久久久久久久久 | av网站在线免费观看 | 亚洲精品在线免费 | 成人精品一区二区三区中文字幕 | 日韩国产在线观看 |