初識(shí)異步編程

異步編程：是指在執(zhí)行某些任務(wù)時(shí)程序可以在等待某個(gè)操作完成的過(guò)程中繼續(xù)執(zhí)行其他任務(wù)，而不是阻塞當(dāng)前線程，這在處理I/O密集型操作(如文件讀取、數(shù)據(jù)庫(kù)查詢、網(wǎng)絡(luò)請(qǐng)求等)時(shí)尤為重要，能夠顯著提高應(yīng)用程序的性能和響應(yīng)能力。

在.net core中異步編程主要通過(guò)async和await關(guān)鍵字來(lái)實(shí)現(xiàn)，結(jié)合Task類(lèi)進(jìn)行異步操作的管理：

async：標(biāo)記方法為異步方法使其能夠包含await表達(dá)式

await：在異步方法中用于等待一個(gè)異步操作完成，允許方法在等待期間繼續(xù)執(zhí)行其他代碼而不會(huì)阻塞線程

異步方法通常返回Task或Task<T> 類(lèi)型：

Task：表示一個(gè)沒(méi)有返回值的異步操作

Task<T>：表示一個(gè)帶返回值的異步操作，其中T是返回值的類(lèi)型

        作用意義：在進(jìn)行項(xiàng)目開(kāi)發(fā)的時(shí)候通常都會(huì)遇到異步編程的使用方式，具備的意義如下：

1）提高應(yīng)用程序響應(yīng)性：異步編程可以使得應(yīng)用程序在等待長(zhǎng)時(shí)間操作(例如網(wǎng)絡(luò)請(qǐng)求或文件讀寫(xiě))時(shí)繼續(xù)處理其他任務(wù)而不會(huì)卡住主線程，比如在桌面應(yīng)用或Web應(yīng)用中用戶界面不會(huì)因等待數(shù)據(jù)加載而變得無(wú)響應(yīng)

2）提升性能：傳統(tǒng)的同步編程會(huì)阻塞線程直到操作完成，這可能導(dǎo)致線程資源的浪費(fèi)，特別是在高并發(fā)場(chǎng)景下異步編程允許線程釋放去處理其他任務(wù)，避免了線程饑餓問(wèn)題，最大化利用CPU資源特別是在I/O密集型操作時(shí)

3）節(jié)省資源：異步操作不需要為每個(gè)操作分配新的線程，因此能夠節(jié)省系統(tǒng)資源，在高并發(fā)情況下異步編程可以顯著減少上下文切換開(kāi)銷(xiāo)

4）適用于I/O密集型應(yīng)用：異步編程特別適用于那些需要大量I/O操作的應(yīng)用，例如網(wǎng)絡(luò)請(qǐng)求、磁盤(pán)讀取、數(shù)據(jù)庫(kù)查詢等。通過(guò)異步操作可以避免長(zhǎng)時(shí)間等待I/O操作而導(dǎo)致的性能瓶頸

接下來(lái)我們通過(guò)異步方法從指定的URL路徑上下載網(wǎng)頁(yè)內(nèi)容，將網(wǎng)頁(yè)內(nèi)容保存到本地文件并輸出下載的內(nèi)容的字節(jié)數(shù)，代碼結(jié)果如下所示：

using System;
using System.IO;
using System.Net.Http;
using System.Threading.Tasks;
namespace Program
{
    class Program
    {
        static async Task Main(string[] args)
        {
            int len = await DownloadHtmlAsync("https://www.baidu.com", @"d:\test\1.txt");
            Console.WriteLine($"Downloaded {len} bytes.");
        }
        static async Task<int> DownloadHtmlAsync(string url, string filename)
        {
            using (HttpClient client = new HttpClient())
            {
                string html = await client.GetStringAsync(url);
                await File.WriteAllTextAsync(filename, html);
                return html.Length;
            }
        }
    }
}

與多線程關(guān)系

異步編程并不等于多線程，這是兩個(gè)概念，異步方法的代碼并不會(huì)自動(dòng)在新線程中執(zhí)行，除非把代碼放到新線程中執(zhí)行，以下做一個(gè)簡(jiǎn)單的演示：

使用異步方法來(lái)執(zhí)行長(zhǎng)時(shí)間運(yùn)行的計(jì)算，通過(guò)Thread.CurrentThread.ManagedThreadId輸出當(dāng)前執(zhí)行線程的ID，可以看到異步方法和線程調(diào)度的關(guān)系如下，這里我們通過(guò)計(jì)算5000*5000的情況避免執(zhí)行太快：

using System;
using System.IO;
using System.Net.Http;
using System.Threading.Tasks;
namespace Program
{
    class Program
    {
        static async Task Main(string[] args)
        {
            Console.WriteLine("之前：" + Thread.CurrentThread.ManagedThreadId);
            double r = await CalcAsync(5000);
            Console.WriteLine("之后：" + Thread.CurrentThread.ManagedThreadId);
        }
        static async Task<double> CalcAsync(int n)
        {
            Console.WriteLine("CalcAsync" + Thread.CurrentThread.ManagedThreadId);
            double result = 0;
            Random rand = new Random();
            for (int i = 1; i <= n*n; i++)
            {
                result += rand.NextDouble();
            }
            return result;
        }
    }
}

那么如何在新的線程中執(zhí)行異步方法呢？這里我們必須手動(dòng)將異步方法放到新的線程中，這里我們只需要將要執(zhí)行的代碼以委托的形式傳遞給Task.Run()，這樣就會(huì)從線程池中取出一個(gè)線程來(lái)執(zhí)行我們的委托，如下可以看到我們的線程已經(jīng)發(fā)送了變化：

如果一個(gè)異步方法只是對(duì)別的異步方法調(diào)用轉(zhuǎn)發(fā)，并沒(méi)有太多復(fù)雜的邏輯，那么就可以去掉異步關(guān)鍵字直接返回Task，如下所示：

對(duì)于多線程來(lái)講，在await調(diào)用的等待期間.net會(huì)把當(dāng)前的線程返回給線程池，等異步方法調(diào)用執(zhí)行完畢之后，框架會(huì)從線程池再取出一個(gè)線程執(zhí)行后續(xù)代碼，怎么理解？比如說(shuō)你進(jìn)入一家餐館服務(wù)器給你遞上一個(gè)菜單，在等待你選菜的時(shí)候服務(wù)你的服務(wù)員可能會(huì)繼續(xù)服務(wù)別人，當(dāng)你點(diǎn)餐完畢提交給服務(wù)員之后，服務(wù)你的服務(wù)員可能就不是剛剛服務(wù)你的人了，就是這么個(gè)意思，當(dāng)然如果異步等待時(shí)間極短，線程可能就不會(huì)發(fā)送變化：

盡管異步編程和多線程都涉及到并發(fā)執(zhí)行任務(wù)，但它們的工作原理和適用場(chǎng)景有所不同，可以把它們看作是兩個(gè)不同的工具用于解決不同類(lèi)型的并發(fā)問(wèn)題：

異步編程：通過(guò)非阻塞的方式執(zhí)行操作，適用于 I/O 密集型任務(wù)，能夠節(jié)省線程資源提高應(yīng)用的響應(yīng)性。

多線程：通過(guò)并行執(zhí)行任務(wù)來(lái)提高CPU密集型任務(wù)的性能，但線程管理復(fù)雜可能帶來(lái)上下文切換和同步問(wèn)題。

異步編程與多線程的結(jié)合：異步編程通過(guò)減少阻塞來(lái)提高效率而多線程通過(guò)并行執(zhí)行來(lái)加速計(jì)算密集型任務(wù)，在某些情況下它們可以結(jié)合使用：例如異步任務(wù)通過(guò)線程池線程執(zhí)行，充分利用多核處理器的計(jì)算能力。

異步編程操作

異步等待：如果想在異步方法中暫停一段時(shí)間的話，這里可以使用 await Task.Delay()的方式，例如下載一個(gè)網(wǎng)址然后等待3秒再下載另一個(gè)，注意這里是不能使用Thread.Sleep()方法的，該方法是阻塞線程用的，異步編程并不適用，這里我們演示一下異步等待的效果，如下所示：

class Program
{
    static async Task Main(string[] args)
    {
        var input = Console.ReadLine();
        Console.WriteLine(input);
        await Task.Delay(3000);
        Console.WriteLine(input+".net core");
    }
}

異步取消：在異步編程中CancellationToken是用于取消異步操作的一種機(jī)制，它提供了一種優(yōu)雅的方式來(lái)中止正在進(jìn)行的操作，當(dāng)用戶操作可能會(huì)長(zhǎng)時(shí)間運(yùn)行時(shí)，例如下載文件、訪問(wèn)數(shù)據(jù)庫(kù)、調(diào)用遠(yuǎn)程API等，CancellationToken用于支持任務(wù)的取消操作，示例如下：

class Program
{
    static async Task Main(string[] args)
    {
        CancellationTokenSource cts = new CancellationTokenSource();
        cts.CancelAfter(3000);
        CancellationToken cToken = cts.Token;
        await Download1Async("https://www.baidu.com", 100, cToken);
    }
    static async Task Download1Async(string url, int n, CancellationToken token)
    {
        using(HttpClient client = new HttpClient())
        {
            for (int i = 0; i < n; i++)
            {
                string html = await new HttpClient().GetStringAsync(url);
                Console.WriteLine($"{DateTime.Now}:{html}");
                if (token.IsCancellationRequested)
                {
                    Console.WriteLine("超時(shí)任務(wù)取消");
                    break;
                }
            }
        }
    }
} 

當(dāng)我們打印數(shù)據(jù)的時(shí)候，請(qǐng)求超過(guò)5秒還沒(méi)有結(jié)束的話我們就手動(dòng)取消異步操作：

Task類(lèi)方法：在Task類(lèi)中有許多方法可以使用，以下是其常用的方法講解：

1）Task.WhenAny()：任何一個(gè)Task完成，Task就完成

2）Task.WhenAll()：所有Task完成Task才完成，用于等待多個(gè)任務(wù)執(zhí)行結(jié)束不在乎順序

3）Task.FromResult()：創(chuàng)建普通數(shù)值的Task對(duì)象

如下我們可同WhenAll拿到所有文件的數(shù)據(jù)：

class Program
{
    static async Task Main(string[] args)
    {
        Task<string> t1 = File.ReadAllTextAsync(@"d:\test\1.txt");
        Task<string> t2 = File.ReadAllTextAsync(@"d:\test\2.txt");
        Task<string> t3 = File.ReadAllTextAsync(@"d:\test\3.txt");
        string[] result = await Task.WhenAll(t1, t2, t3);
    } 
} 

到此這篇關(guān)于如何在 .NET Core 中輕松實(shí)現(xiàn)異步編程并提升性能的文章就介紹到這了,更多相關(guān) .NET Core異步編程內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論