这篇文章主要介绍“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怎么创建”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。