欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

C#并發(fā)編程之Task類詳解

 更新時(shí)間:2023年03月27日 08:41:57   作者:微小冷  
Task是建立在線程池之上的一種多線程技術(shù),它的出現(xiàn)使Thread成為歷史。其使用方法非常簡(jiǎn)單,本文就來(lái)通過(guò)幾個(gè)示例為大家講講它的具體使用吧

Task.Run

Task是建立在線程池之上的一種多線程技術(shù),它的出現(xiàn)使Thread成為歷史。其使用方法非常簡(jiǎn)單,下面在頂級(jí)語(yǔ)句中做一個(gè)簡(jiǎn)單的例子

void printN(string name)
{
    for (int i = 0; i < 3; i++)
    {
        Console.WriteLine($"{name}:{i}");
        Task.Delay(1000).Wait();
    }
}
Task.Run(() => printN("t1"));
Task.Run(() => printN("t2"));
Task.Run(() => printN("t3")).Wait();

運(yùn)行后,命令行中的結(jié)果為

t3:0
t2:0
t1:0
t2:1
t3:1
t1:1
t1:2
t2:2
t3:2

Task.Run通過(guò)輸入一個(gè)委托,創(chuàng)建一個(gè)任務(wù)并執(zhí)行,同時(shí)返回一個(gè)Task對(duì)象。

Task在執(zhí)行過(guò)程中,并不會(huì)等待命令行的主線程,所以在最后啟動(dòng)的Task后跟上Wait,即等待該線程結(jié)束之后,主線程才結(jié)束,從而讓printN的輸出內(nèi)容得以在終端中顯示。

Task類

上面的Task.Run的案例也可以用Task來(lái)實(shí)現(xiàn),但Task對(duì)象創(chuàng)建后,并不會(huì)馬上運(yùn)行,而會(huì)在Start()之后運(yùn)行,示例如下

void printN(object name)
{
    for (int i = 0; i < 3; i++)
    {
        Console.WriteLine($"{name}:{i}");
        Task.Delay(1000).Wait();
    }
}
Action<object> act = (object name) => printN(name);

Task t1 = new Task(()=>printN("t1"));
new Task(act, "t2").Start();
Task t3 = new Task(act, "t3");
t1.Start();
t3.Start();
t3.Wait();

返回值

除了Task,C#還提供了帶有返回值的封裝,即Task<TResult>,可通過(guò)泛型的方式聲明返回值。

但是,Task說(shuō)到底還是個(gè)類,而非函數(shù),這個(gè)返回值并不會(huì)在構(gòu)造函數(shù)中體現(xiàn)出來(lái),也不經(jīng)過(guò)Start()函數(shù),若想使用這個(gè)返回值,需要經(jīng)由ContinueWith函數(shù)。

ContinueWith的功能是在某一個(gè)線程執(zhí)行完畢之后,開啟下一個(gè)線程。如果執(zhí)行完畢的線程有返回值的話,那么ContinueWith也可以利用這個(gè)返回值。

其調(diào)用方法為

Task<int> task = new Task<int>(() =>
{
    Console.WriteLine("這里是task");
    return 100;
});

//任務(wù)完成時(shí)執(zhí)行處理。
Task cwt = task.ContinueWith(t =>
{
    Console.WriteLine($"這里是Continue,task返回值為{t.Result}");
});
task.Start();
cwt.Wait();

其中,cwt需要等待task執(zhí)行完畢之后再執(zhí)行。

等待和延續(xù)

在前面的案例中,已經(jīng)講解了基本的等待函數(shù)Wait和基本的延續(xù)函數(shù)ContinueWith。C#中提供了更多的等待與延續(xù)函數(shù),以更加靈活地操作線程列表。

阻塞主線程不阻塞主線程
任意線程執(zhí)行完畢即可執(zhí)行WaitAnyWhenAny
所有線程執(zhí)行完畢方可執(zhí)行WaitAllWhenAll

其中, WhenAny, WhenAll需要與ContinueWith配合食用,當(dāng)WhenXX結(jié)束之后,即執(zhí)行ContinueWith中的內(nèi)容,這個(gè)過(guò)程并不阻塞主線程。

為了驗(yàn)證這些函數(shù)的功能,先創(chuàng)建一個(gè)線程列表

Action<string, int> log = (name, time) =>
{
    Console.WriteLine($"{name} Start...");
    Task.Delay(time).Wait();
    Console.WriteLine($"{name} Stop!");
};

Task[] tasks = new Task[]
{
    Task.Run(() => log("A",3000)),
    Task.Run(() => log("B",1000)),
    Task.Run(() => log("C",2000))
};

然后依次執(zhí)行這幾個(gè)等待函數(shù),看看結(jié)果

Task.WaitAny(tasks); 此時(shí)當(dāng)B執(zhí)行完畢之后,阻塞就結(jié)束了,從而主線程結(jié)束。

B Start...
A Start...
C Start...
B Stop!

Task.WaitAll(tasks); 這次當(dāng)所有線程執(zhí)行完畢之后,程序才結(jié)束。

A Start...
B Start...
C Start...
B Stop!
C Stop!
A Stop!

下面這兩組測(cè)試,現(xiàn)象和前兩組相似,區(qū)別無(wú)非是在后面加上一段字符串而已。

Task.WhenAny(tasks).ContinueWith(x => Console.WriteLine($"某個(gè)Task執(zhí)行完畢")).Wait();
Task.WhenAll(tasks.ToArray()).ContinueWith(x => Console.WriteLine("所有Task執(zhí)行完畢")).Wait();

取消任務(wù)

C#提供了CancellationToken作為Task取消的標(biāo)識(shí),通過(guò)調(diào)用Cancel()函數(shù),可將其取消標(biāo)志更改為True,從而在線程執(zhí)行過(guò)程中,起到取消線程的作用。

首先創(chuàng)建一個(gè)可以取消的線程函數(shù)

int TaskMethod(string name, int seconds, CancellationToken token)
{
    Console.WriteLine($"{name} 正在運(yùn)行");
    for (int i = 0; i < seconds; i++)
    {
        Task.Delay(1000).Wait();
        Console.WriteLine($"{name}: {i}s");
        if (token.IsCancellationRequested)
            return -1;
    }
    return 1;
}

功能很簡(jiǎn)單,就是跑循環(huán),在跑循環(huán)的過(guò)程中,如果token指明取消,則線程結(jié)束。

下面測(cè)試一下

var cts = new CancellationTokenSource();
var task = new Task<int>(() => TaskMethod("Task 1", 5, cts.Token), cts.Token);
Console.WriteLine($"線程狀態(tài):{task.Status}");
task.Start();
Console.WriteLine($"線程狀態(tài):{task.Status}");
Task.Delay(3000).Wait();
cts.Cancel();
Console.WriteLine($"線程狀態(tài):{task.Status}");
Task.Delay(1000).Wait();
Console.WriteLine($"線程狀態(tài):{task.Status}");

效果為如下

線程狀態(tài):Created
線程狀態(tài):WaitingToRun
Task 1 正在運(yùn)行
Task 1: 0s
Task 1: 1s
線程狀態(tài):Running
Task 1: 2s
線程狀態(tài):RanToCompletion

在整個(gè)線程執(zhí)行的過(guò)程中,共出現(xiàn)了四種狀態(tài)

  • Created 此時(shí)線程剛創(chuàng)建,但并未執(zhí)行
  • WaitingToRun 此時(shí)已經(jīng)執(zhí)行了Start函數(shù),但線程還沒(méi)反應(yīng)過(guò)來(lái),所以是等待執(zhí)行
  • Running 此時(shí)已經(jīng)執(zhí)行了Cancel,但task中的循環(huán)每1秒檢測(cè)1次,在Cancel執(zhí)行完之后,還沒(méi)來(lái)得及檢測(cè),就查詢了線程的狀態(tài),所以線程仍在運(yùn)行
  • RanToCompletion 在等待1秒之后,終于檢測(cè)到token變了,從而線程結(jié)束。

到此這篇關(guān)于C#并發(fā)編程之Task類詳解的文章就介紹到這了,更多相關(guān)C#并發(fā)編程 Task類內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

最新評(píng)論