C#異步編程Task的創(chuàng)建方式
更新時間：2022年04月20日 16:31:25 作者：農(nóng)碼一生
這篇文章介紹了C#異步編程Task的創(chuàng)建方式，文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下
一、簡介
ThreadPool相比Thread來說具備了很多優(yōu)勢，但是ThreadPool卻又存在一些使用上的不方便。比如：
Task支持線程的取消、完成、失敗通知等交互性操作，但是ThreadPool不支持；
Task支持線程執(zhí)行的先后次序，但是ThreadPool不支持；；
以往，如果開發(fā)者要實現(xiàn)上述功能，需要完成很多額外的工作，現(xiàn)在，F(xiàn)CL中提供了一個功能更強(qiáng)大的概念：Task。Task在線程池的基礎(chǔ)上進(jìn)行了優(yōu)化，并提供了更多的API。在FCL4.0中，如果我們要編寫多線程程序，Task顯然已經(jīng)優(yōu)于傳統(tǒng)的方式。
Task t = new Task(() =>
{
Console.WriteLine("Start……");
//模擬工作過程
Thread.Sleep(5000);
});
t.Start();
t.ContinueWith((task) =>
{
Console.WriteLine("Already Finished，States：");
Console.WriteLine("IsCanceled={0}\tIsCompleted={1}\tIsFaulted={2}", task.IsCanceled, task.IsCompleted, task.IsFaulted);
});
Console.ReadKey();二、Task創(chuàng)建
無返回值創(chuàng)建方式
線程引用方法：
static void TaskMethod(string name)
{
Console.WriteLine("Task: {0} is running on a thread id {1}. Is thread pool thread: {2}",
name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
}方式一：
//方式一
var t1 = new Task(() => TaskMethod("Task_1"));
t1.Start();
//等待所有任務(wù)結(jié)束
//任務(wù)的狀態(tài):
//Start之前為:Created
//Start之后為:WaitingToRun
Task.WaitAll(t1);////等待所有任務(wù)結(jié)束方式二：
//方式二
Task.Run(() => TaskMethod("Task_2"));方式三：
//方式三
Task.Factory.StartNew(() => TaskMethod("Task_3")); //直接異步的方法
//或者
var t3 = Task.Factory.StartNew(() => TaskMethod("Task_3"));
Task.WaitAll(t3);//等待所有任務(wù)結(jié)束
//任務(wù)的狀態(tài)
//Start之前為:Running
//Start之后為:Running實例：
class Program
{
static void Main(string[] args)
{
var t1 = new Task(() => TaskMethod("Task_1"));
var t2 = new Task(() => TaskMethod("Task_2"));
t2.Start();
t1.Start();
Task.WaitAll(t1, t2);
Task.Run(() => TaskMethod("Task_3"));
Task.Factory.StartNew(() => TaskMethod("Task_4"));
//標(biāo)記為長時間運行任務(wù),則任務(wù)不會使用線程池,而在單獨的線程中運行。
Task.Factory.StartNew(() => TaskMethod("Task_5"), TaskCreationOptions.LongRunning);
#region 常規(guī)的使用方式
Console.WriteLine("主線程執(zhí)行業(yè)務(wù)處理.");
//創(chuàng)建任務(wù)
Task task = new Task(() =>
{
Console.WriteLine("使用System.Threading.Tasks.Task執(zhí)行異步操作.");
for (int i = 0; i < 10; i++)
{
Console.WriteLine(i);
}
});
//啟動任務(wù),并安排到當(dāng)前任務(wù)隊列線程中執(zhí)行任務(wù)(System.Threading.Tasks.TaskScheduler)
task.Start();
Console.WriteLine("主線程執(zhí)行其他處理");
task.Wait();
#endregion
Thread.Sleep(TimeSpan.FromSeconds(1));
Console.ReadLine();
}
static void TaskMethod(string name)
{
Console.WriteLine("Task {0} is running on a thread id {1}. Is thread pool thread: {2}",
name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
}
}結(jié)果：
async/await的實現(xiàn)方式:
class Program
{
async static void AsyncFunction()
{
await Task.Delay(1);
Console.WriteLine("使用System.Threading.Tasks.Task執(zhí)行異步操作.");
for (int i = 0; i < 10; i++)
{
Console.WriteLine(string.Format("AsyncFunction:i={0}", i));
}
}
public static void Main()
{
Console.WriteLine("主線程執(zhí)行業(yè)務(wù)處理.");
AsyncFunction();
Console.WriteLine("主線程執(zhí)行其他處理");
for (int i = 0; i < 10; i++)
{
Console.WriteLine(string.Format("Main:i={0}", i));
}
Console.ReadLine();
}
}結(jié)果：
帶返回值方式
線程引用方法
static Task<int> CreateTask(string name)
{
return new Task<int>(() => TaskMethod1(name));
} static int TaskMethod1(string name)
{
Console.WriteLine("Task {0} is running on a thread id {1}. Is thread pool thread: {2}",
name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
Thread.Sleep(TimeSpan.FromSeconds(2));
return 42;
}方式四：
//方式四
Task<int> task = CreateTask("Task_1");
task.Start();
int result = task.Result;實例：
class Program
{
static Task<int> CreateTask(string name)
{
return new Task<int>(() => TaskMethod(name));
}
static void Main(string[] args)
{
TaskMethod("Main Thread Task");
Task<int> task = CreateTask("Task_1");
task.Start();
int result = task.Result;
Console.WriteLine("Task_1 Result is: {0}", result);
task = CreateTask("Task_2");
//該任務(wù)會運行在主線程中
task.RunSynchronously();
result = task.Result;
Console.WriteLine("Task_2 Result is: {0}", result);
task = CreateTask("Task_3");
Console.WriteLine(task.Status);
task.Start();
while (!task.IsCompleted)
{
Console.WriteLine(task.Status);
Thread.Sleep(TimeSpan.FromSeconds(0.5));
}
Console.WriteLine(task.Status);
result = task.Result;
Console.WriteLine("Task_3 Result is: {0}", result);
#region 常規(guī)使用方式
//創(chuàng)建任務(wù)
Task<int> getsumtask = new Task<int>(() => Getsum());
//啟動任務(wù),并安排到當(dāng)前任務(wù)隊列線程中執(zhí)行任務(wù)(System.Threading.Tasks.TaskScheduler)
getsumtask.Start();
Console.WriteLine("主線程執(zhí)行其他處理");
//等待任務(wù)的完成執(zhí)行過程。
getsumtask.Wait();
//獲得任務(wù)的執(zhí)行結(jié)果
Console.WriteLine("任務(wù)執(zhí)行結(jié)果：{0}", getsumtask.Result.ToString());
Console.ReadLine();
#endregion
}
static int TaskMethod(string name)
{
Console.WriteLine("Task: {0} is running on a thread id {1}. Is thread pool thread: {2}",
name, Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread);
Thread.Sleep(TimeSpan.FromSeconds(2));
return 42;
}
static int Getsum()
{
int sum = 0;
Console.WriteLine("使用Task執(zhí)行異步操作.");
for (int i = 0; i < 100; i++)
{
sum += i;
}
return sum;
}
}結(jié)果：
async/await的實現(xiàn):
class Program
{
public static void Main()
{
var ret1 = AsyncGetsum();
Console.WriteLine("主線程執(zhí)行其他處理");
for (int i = 1; i <= 3; i++)
Console.WriteLine("Call Main()");
int result = ret1.Result; //阻塞主線程
Console.WriteLine("任務(wù)執(zhí)行結(jié)果：{0}", result);
Console.ReadLine();
}
async static Task<int> AsyncGetsum()
{
await Task.Delay(1);
int sum = 0;
Console.WriteLine("使用Task執(zhí)行異步操作.");
for (int i = 0; i < 100; i++)
{
sum += i;
}
return sum;
}
}結(jié)果：
到此這篇關(guān)于C#創(chuàng)建異步Task的文章就介紹到這了。希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要為大家詳細(xì)介紹了HttpHelper類的使用方法，HttpHelper類及調(diào)用，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-06-06
C#使用SqlDataAdapter對象獲取數(shù)據(jù)的方法
這篇文章主要介紹了C#使用SqlDataAdapter對象獲取數(shù)據(jù)的方法,結(jié)合實例形式較為詳細(xì)的分析了SqlDataAdapter對象獲取數(shù)據(jù)具體步驟與相關(guān)使用技巧,需要的朋友可以參考下2016-02-02
本文主要介紹了Dictionary集合的7種最基礎(chǔ)的用法，包括創(chuàng)建、添加、查找、遍歷、刪除等方法，程序都是由簡入繁，希望能通過閱讀簡單的示例，給大家一些啟發(fā)。2016-03-03
本文主要介紹了C# winform ListView的基本操作，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-01-01
本文主要介紹了C# salt+hash加密規(guī)則、C# salt產(chǎn)生偽隨機(jī)數(shù)原理、hash原理、使用hash來加密的原因等等。具有一定的參考價值，下面跟著小編一起來看下吧2017-01-01
C#使用ThreadPriority設(shè)置線程優(yōu)先級
這篇文章介紹了C#使用ThreadPriority設(shè)置線程優(yōu)先級的方法，文中通過示例代碼介紹的非常詳細(xì)。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-04-04
c#幾種數(shù)據(jù)庫的大數(shù)據(jù)批量插入（SqlServer、Oracle、SQLite和MySql）
這篇文章主要介紹了c#幾種數(shù)據(jù)庫的大數(shù)據(jù)批量插入（SqlServer、Oracle、SQLite和MySql），需要的朋友可以了解一下。2016-11-11
這篇文章主要介紹了C#異步編程由淺入深(二)之Async/Await的作用,本文通過實例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-03-03
使用以上方法必須對dcom進(jìn)行配置，給用戶使用office的權(quán)限2012-10-10
Unity 實現(xiàn)框選游戲戰(zhàn)斗單位的思路詳解
這篇文章主要介紹了Unity 如何實現(xiàn)框選游戲戰(zhàn)斗單位,本文簡單介紹如何實現(xiàn)即時戰(zhàn)略游戲中框選戰(zhàn)斗單位的功能，需要的朋友可以參考下2022-12-12