溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要介紹“C#異步編程Task怎么創建”，在日常操作中，相信很多人在C#異步編程Task怎么創建問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”C#異步編程Task怎么創建”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！
ThreadPool相比Thread來說具備了很多優勢，但是ThreadPool卻又存在一些使用上的不方便。比如：
Task支持線程的取消、完成、失敗通知等交互性操作，但是ThreadPool不支持；
Task支持線程執行的先后次序，但是ThreadPool不支持；；
以往，如果開發者要實現上述功能，需要完成很多額外的工作，現在，FCL中提供了一個功能更強大的概念：Task。Task在線程池的基礎上進行了優化，并提供了更多的API。在FCL4.0中，如果我們要編寫多線程程序，Task顯然已經優于傳統的方式。
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();線程引用方法：
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();
//等待所有任務結束
//任務的狀態:
//Start之前為:Created
//Start之后為:WaitingToRun
Task.WaitAll(t1);////等待所有任務結束 //方式二
Task.Run(() => TaskMethod("Task_2")); //方式三
Task.Factory.StartNew(() => TaskMethod("Task_3")); //直接異步的方法
//或者
var t3 = Task.Factory.StartNew(() => TaskMethod("Task_3"));
Task.WaitAll(t3);//等待所有任務結束
//任務的狀態
//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"));
//標記為長時間運行任務,則任務不會使用線程池,而在單獨的線程中運行。
Task.Factory.StartNew(() => TaskMethod("Task_5"), TaskCreationOptions.LongRunning);
#region 常規的使用方式
Console.WriteLine("主線程執行業務處理.");
//創建任務
Task task = new Task(() =>
{
Console.WriteLine("使用System.Threading.Tasks.Task執行異步操作.");
for (int i = 0; i < 10; i++)
{
Console.WriteLine(i);
}
});
//啟動任務,并安排到當前任務隊列線程中執行任務(System.Threading.Tasks.TaskScheduler)
task.Start();
Console.WriteLine("主線程執行其他處理");
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);
}
}結果：
class Program
{
async static void AsyncFunction()
{
await Task.Delay(1);
Console.WriteLine("使用System.Threading.Tasks.Task執行異步操作.");
for (int i = 0; i < 10; i++)
{
Console.WriteLine(string.Format("AsyncFunction:i={0}", i));
}
}
public static void Main()
{
Console.WriteLine("主線程執行業務處理.");
AsyncFunction();
Console.WriteLine("主線程執行其他處理");
for (int i = 0; i < 10; i++)
{
Console.WriteLine(string.Format("Main:i={0}", i));
}
Console.ReadLine();
}
}結果：
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");
//該任務會運行在主線程中
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 常規使用方式
//創建任務
Task<int> getsumtask = new Task<int>(() => Getsum());
//啟動任務,并安排到當前任務隊列線程中執行任務(System.Threading.Tasks.TaskScheduler)
getsumtask.Start();
Console.WriteLine("主線程執行其他處理");
//等待任務的完成執行過程。
getsumtask.Wait();
//獲得任務的執行結果
Console.WriteLine("任務執行結果：{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執行異步操作.");
for (int i = 0; i < 100; i++)
{
sum += i;
}
return sum;
}
}結果：
class Program
{
public static void Main()
{
var ret1 = AsyncGetsum();
Console.WriteLine("主線程執行其他處理");
for (int i = 1; i <= 3; i++)
Console.WriteLine("Call Main()");
int result = ret1.Result; //阻塞主線程
Console.WriteLine("任務執行結果：{0}", result);
Console.ReadLine();
}
async static Task<int> AsyncGetsum()
{
await Task.Delay(1);
int sum = 0;
Console.WriteLine("使用Task執行異步操作.");
for (int i = 0; i < 100; i++)
{
sum += i;
}
return sum;
}
}結果：
到此，關于“C#異步編程Task怎么創建”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注億速云網站，小編會繼續努力為大家帶來更多實用的文章！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
