C#中的Task.Delay()延迟与异步执⾏返回结果1.暂停⼀段时间
public static Task ShortDelay(TimeSpan delay)
{
await Task.Delay(delay);
Console.WriteLine(string.Format("延迟{0}", delay));
}
解析:
异步编程使⽤async与await关键字,搭配返回Task或其泛型
async的存在是为了代码中await的⽣效
如果没有返回值,更推荐写为Task,⽽不是void
Task.Delay()是异步编程提供的延迟⽅法,如果你想延迟两秒,可以Task.Delay(2000);
当Task.Delay(delay);执⾏后,会异步延迟delay的时间,在延迟的同时,执⾏下⽅的Console
当这⾏代码前+await,会等待异步延迟的执⾏结束后,执⾏下⽅的Console
2.实现简单的指数退避策略
pulic static async Task ToDoRetries()
{
var nextDelay = TimeSpan.FromSeconds(1);
for(int i = 0; i<3; i++)
{
return await DoSometingAsync();
nextDelay += nextDelay;
await Task.Delay(nextDelat);
}
}
解析:
退避策略:防⽌被访问的频繁被阻塞
3.实现超时处理
private static async Task<string> ToDoAsync()
{
await Task.Delay(TimeSpan.FromSeconds(3));
return "To Do Success!";
}
public static async Task<string> ToDoWithTimeOut()
{
var toDoTask = ToDoAsync();
var timeOutTask = Task.Delay(TimeSpan.FormSeconds(3));
var completedTask = await Task.WhenAny(toDoTask, timeOutTask);
if(completedTask == timeOutTask)
{
return "";
}
return await toDoTask;
}
解析:
Task.WhenAny(toDoTask, timeOutTask);是只要其中有⼀个异步,或者说是任务完成,就返回
最费解就是最后最后⼀⾏,toDoTask是⼀个Task,并不是异步⽅法,为什么前⾯还有await,当将await去掉后:
断点后发现,toDoTask是⼀个Task类型,其中有id,status等属性,如果在Task类型前+await,获取的是Task类型中Result属性的值
出处:
===============================================================================================================以下是我⾃⼰在WinConsole程序中的测试:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConsoleApp1
{
class Program
{
static void Main(string[] args)
{
var t1 = AsyncGetsum();
Console.WriteLine(t1.Result); //会阻塞主线程
var t = ToDoWithTimeOut();
Console.WriteLine(t.Result); //会阻塞主线程
Console.ReadKey();
}
private static async Task<int> AsyncGetsum()
{
int sum = 0;
for (int i = 0; i <= 100; i++)
{
sum += i;
System.Diagnostics.Debug.WriteLine("sum += " + i);
await Task.Delay(50);
}
return sum;
}
private static async Task<string> ToDoAsync()
{
await Task.Delay(TimeSpan.FromSeconds(3));
return"To Do Success!";
}
public static async Task<string> ToDoWithTimeOut()
{
var toDoTask = ToDoAsync();
var timeOutTask = Task.Delay(TimeSpan.FromSeconds(2));
var completedTask = await Task.WhenAny(toDoTask, timeOutTask);
if (completedTask == timeOutTask)
{
return"No";
}
return await toDoTask;
}
}
}
以下是我⾃⼰在WinForm程序中的测试:
private async Task<int> AsyncGetsum()
{
int sum = 0;
label3.Text = ("使⽤Task执⾏异步操作." + DateTime.Now.ToString("HH:mm:ss.fff"));
for (int i = 0; i <= 100; i++)
{
sum += i;
System.Diagnostics.Debug.WriteLine("sum += " + i);
await Task.Delay(50);
//label4.Text = sum.ToString(); //可以在异步⽅法⾥直接赋值操作
}
return sum;
}
private async Task<string> ToDoAsync()
{
await Task.Delay(TimeSpan.FromSeconds(1));
return"To Do Success!";
}
public async Task<string> ToDoWithTimeOut()
{
var toDoTask = ToDoAsync();
var timeOutTask = Task.Delay(TimeSpan.FromSeconds(2));
var completedTask = await Task.WhenAny(toDoTask, timeOutTask);
if (completedTask == timeOutTask)
{
return"No";
}
return await toDoTask;
}
private async void btTaskTest_Click(object sender, EventArgs e)
{
//Task<string> retStr = ToDoWithTimeOut(); //直接调⽤返回的是Task对象
string res = await ToDoWithTimeOut(); //使⽤await 修饰符返回的是Task运⾏的结果值
label4.Text = retStr.Result; //会阻塞主线程
label4.Text = res;
var ret1 = AsyncGetsum();
label1.Text = ("主线程执⾏其他处理 :" + DateTime.Now.ToString("HH:mm:ss.fff"));
for (int i = 1; i <= 3; i++)
System.Threading.Thread.Sleep(400); //模拟主线程阻塞
await ret1.ContinueWith((Task<int> s) => //此⾏语句的前⾯加上await则表⽰当前代码块是同步执⾏还是异步执⾏,直接影响该代码块后⾯的代码执⾏时间
{
int result = ret1.Result; //会阻塞主线程
string msg = string.Format("任务执⾏结果:{0} == " + DateTime.Now.ToString("HH:mm:ss.fff"), result);
System.Diagnostics.Debug.WriteLine(msg);
Comm.UtilityHelper.UpdateUI(label4, msg);
});
label2.Text = ("Call Main() == " + DateTime.Now.ToString("HH:mm:ss.fff"));
}
上⾯的代码我都已经加了注释说明了,不懂的可以问,问了估计我也不会回答。
经过以上两个程序的测试,当调⽤返回的Task对象的Result的时候,在命令⾏程序中会阻塞主线程,等待Task对象的执⾏完成后会继续执⾏。
⽽在WinForm的程序中,则会直接退出程序,不会有任何返回。如果想获取到Task的异步的返回值,则可以使⽤Task对象的ContinueWith试试看。
(联想:所以在很多时候调⽤第三⽅的DLL的时候,会有莫名其妙的⽅法,不会有任何的返回,⽐如之前的视频下载取消,点击按钮后⽆任何响应)
===============================================================================================================
C#中的Task.Delay()和Thread.Sleep()
1. Thread.Sleep()是同步延迟,Task.Delay()是异步延迟。
2. Thread.Sleep()会阻塞线程,Task.Delay()不会。
3. Thread.Sleep()不能取消,Task.Delay()可以。
4. Task.Delay()实质创建⼀个运⾏给定时间的任务,Thread.Sleep()使当前线程休眠给定时间。
5. 反编译Task.Delay(),基本上讲它就是个包裹在任务中的定时器。
6. Task.Delay()和Thread.Sleep()最⼤的区别是Task.Delay()旨在异步运⾏,在同步代码中使⽤Task.Delay()是没有意义的;在异步代码中使⽤Thread.Sleep()是⼀个⾮常糟糕的主
意。通常使⽤await关键字调⽤Task.Delay()。
7. 我的理解:Task.Delay(),async/await和CancellationTokenSource组合起来使⽤可以实现可控制的异步延迟。
参考资料:
(评论区有争议)
以下是本⼈调试时的代码:
代码1:
using System;
using System.Threading;
using System.Threading.Tasks;
namespace Delay_And_Sleep
{
class Program
{
static void Main(string[] args)
{
await和async使用方法Task.Factory.StartNew(delegate
{
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ****** 开始Sleep()");
for (int i = 1; i < 20; i++)
{
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ***Sleep*** " + i);
Thread.Sleep(100);
}
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ****** 结束Sleep()");
});
Task.Factory.StartNew(() =>
{
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ====== 开始Delay()");
for (int i = 101; i < 120; i++)
{
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ===Delay=== " + i); Task.Delay(100);//需要4.5及以上
}
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ====== 结束Delay()"); });
//Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "press enter to close . . .")
; Console.ReadLine();
}
}
}
运⾏结果:
代码2:
using System;
using System.Threading.Tasks;
namespace Delay_async_await
{
class Program
{
//该段代码通过async/awatit实现“同步”Delay
static void Main(string[] args)
{
Task.Factory.StartNew(async () =>
{
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ====== 开始Delay()");
for (int i = 101; i < 120; i++)
{
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ===Delay=== " + i);
await Task.Delay(100);//需要4.5及以上
}
Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + " ====== 结束Delay()"); });
//Console.WriteLine(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "press enter to close . . ."); Console.ReadLine();
}
}
}
运⾏结果:
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。
发表评论