C#利用Task实现任务超时多任务一起执行的方法

前言

其实Task跟线程池ThreadPool的功能类似，不过写起来更为简单，直观。代码更简洁了，使用Task来进行操作。可以跟线程一样可以轻松的对执行的方法进行控制。

创建Task有两种方式，一种是使用构造函数创建，另一种是使用 Task.Factory.StartNew 进行创建。

如下代码所示

1.使用构造函数创建Task

Task t1 = new Task(MyMethod);

2.使用Task.Factory.StartNew 进行创建Task

Task t1 = Task.Factory.StartNew(MyMethod);

其实这两种方式都是一样的，Task.Factory 是对Task进行管理，调度管理这一类的。好学的伙伴们，可以深入研究。这不是本文的范畴，需要的朋友可以进去我们进行学习。

本文将充分使用Task的异步功能，下面来一起看看详细的介绍吧。

代码实现：

1.实现了任务超时 退出任务

2.多个任务一起执行

  /// <summary>
  ///做事 需要 ms秒 才能完成
  /// </summary>
  /// <param name="time"></param>
  /// <returns></returns>
  static async Task<string> Doing(int time, string name = "我")
  {
   Console.WriteLine(name+"来了");
   await Task.Delay(TimeSpan.FromMilliseconds(time));
   return string.Format("这活{1}干了：{0}ms ", time,name);
  }
  /// <summary>
  /// 设定超时任务 如果超时返回
  /// </summary>
  /// <param name="needTimeOut"></param>
  /// <returns></returns>
  static async Task<string> TimeOut(bool needTimeOut)
  {
   Console.WriteLine(needTimeOut);
   var t=new Stopwatch();
   t.Start();
   var timeOutTask = Task.Delay(150);//1.设定一个超时的任务
   var doing = Doing(needTimeOut ? 100 : 300);//2. 真正需要执行的任务
   var task = await Task.WhenAny(doing,timeOutTask);//返回任何一个完成的任务
   if (task == timeOutTask)//如果超时任务先完成了 就返回 很可惜 他没有完成！
   {
    return "很可惜 他没有完成！";
   }
   t.Stop();
   Console.WriteLine("耗时："+t.Elapsed.TotalMilliseconds);
   return await doing;
  }
  /// <summary>
  /// 多任务一起执行
  /// </summary>
  /// <returns></returns>
  static async Task Tasks()
  {
   var t = new Stopwatch();
   t.Start();
   var list=new List<string>();
   var t1 = Doing(1000, "1000");//1.定义任务
   var t2 = Doing(1500, "1500");
   var t3 = Doing(1200, "1200");
   var tasks = new[] {t1, t2, t3};//2.任务组
   var process = tasks.Select(async tt =>//3.等待任务结束 并保存值
   {
    var result = await tt;
    list.Add(result);
   });
   await Task.WhenAll(process);//4.等待处理完全
   foreach (var i in list)//5.查看结果
   {
    Console.WriteLine(i);
   }
   t.Stop();
   Console.WriteLine("耗时：" + t.Elapsed.TotalMilliseconds);
  }

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对我们的支持。

赞 (0)

相关推荐

  • 详解C#中 Thread，Task，Async/Await，IAsyncResult的那些事儿

    详解C#中 Thread，Task，Async/Await，IAsyncResult的那些事儿

    说起异步,Thread,Task,async/await,IAsyncResult 这些东西肯定是绕不开的,今天就来依次聊聊他们 1.线程(Thread) 多线程的意义在于一个应用程序中,有多个执行部分可以同时执行:对于比较耗时的操作(例如io,数据库操作),或者等待响应(如WCF通信)的操作,可以单独开启后台线程来执行,这样主线程就不会阻塞,可以继续往下执行:等到后台线程执行完毕,再通知主线程,然后做出对应操作! 在C#中开启新线程比较简单 static void Main(string[]

  • c#异步task示例分享(异步操作)

    c# Task异步操作 复制代码 代码如下: using System;using System.Threading;using System.Threading.Tasks; namespace ConsoleApplication18{    class Program    {        static void Main(string[] args)        {            Func<string, string> _processTimeFunc = new Fun

  • windows下C#定时管理器框架Task.MainForm详解

    windows下C#定时管理器框架Task.MainForm详解

    入住博客园4年多了,一直都是看别人的博客,学习别人的知识,为各个默默无私贡献自己技术总结的朋友们顶一个:这几天突然觉得是时候加入该队列中,贡献出自己微弱的力量,努力做到每个月有不同学习总结,知识学习的分享文章.以下要分享的是花了两天时间编写+测试的windows下C#定时管理器框架-Task.MainForm. 目的: 随着这五年在几个公司做不同职位的.net研发者,发现各个公司都或多或少会对接一些第三方合作的接口或者数据抓取功能,都是那种各个服务直接没有关联性功能,开发人员也可能不是一个人,使

  • C#利用Task实现任务超时多任务一起执行的方法

    前言 其实Task跟线程池ThreadPool的功能类似,不过写起来更为简单,直观.代码更简洁了,使用Task来进行操作.可以跟线程一样可以轻松的对执行的方法进行控制. 创建Task有两种方式,一种是使用构造函数创建,另一种是使用 Task.Factory.StartNew 进行创建. 如下代码所示 1.使用构造函数创建Task Task t1 = new Task(MyMethod); 2.使用Task.Factory.StartNew 进行创建Task Task t1 = Task.Fact

  • Nodejs回调加超时限制两种实现方法

    Nodejs回调加超时限制两种实现方法 Nodejs下的IO操作都是异步的,有时候异步请求返回太慢,不想无限等待回调怎么办呢?我们可以给回调函数加一个超时限制,到一定时间还没有回调就表示失败,继续后面的步骤. 方案1:用async的parallel实现 在这里我用到了async的parallel方法,parallel可以让若干个异步回调的方法并行执行,正常情况下,所有回调函数都完成后会汇集到parallel最终的回调函数里,但是有一种例外,如果其中一个步骤有错误抛出并直接调用parallel最终

  • 利用MySQL系统数据库做性能负载诊断的方法

    某大师曾说过,像了解自己的老婆 一样了解自己管理的数据库,个人认为包含了两个方面的了解: 1,在稳定性层面来说,更多的是关注高可用.读写分离.负载均衡,灾备管理等等high level层面的措施(就好比要保证生活的稳定性) 2,在实例级别的来说,需要关注内存.IO.网络,热点表,热点索引,top sql,死锁,阻塞,历史上执行异常的SQL(好比生活品质细节)MySQL的performance_data库和sys库提供了非常丰富的系统日志数据,可以帮助我们更好地了解非常细节的,这里简单地列举出来了

  • 利用FlubuCore用C#来写DevOps脚本的方法详解

    前言 随着近些年微服务的流行,有越来越多的开发者和团队所采纳和使用,它的确提供了很多的优势也解决了很多的问题,但是我们也知道也并不是银弹,提供优势的同时它也给我们的开发人员和团队也带来了很多的挑战. 为了迎接或者采用这些新技术,开发团队需要更加注重一些流程或工具的使用,这样才能更好的适应这些新技术所带来的一些问题. 对于流程行问题,敏捷的Scrum能够很好的提升产品开发团队之间的协作问题,那么对于应用变的越来越复杂这种情况,它最直接的问题就是带来了开发运维的复杂性,这个时候我们就需要使用工具来解

  • asp.net利用cookie保存用户密码实现自动登录的方法

    本文实例讲述了asp.net利用cookie保存用户密码实现自动登录的方法.分享给大家供大家参考.具体分析如下: 在asp.net中可以用cookie保存用户的帐户密码实现自动登录的功能,但是需要强调一下,cookie在客户端保存,是不安全的,推荐使用md5加密保存. 下面分析一下在asp.net中cookie的创建.提取与销毁的方法: 创建cookie 复制代码 代码如下: //向客户端写入Cookie HttpCookie hcUserName1 = new HttpCookie("unam

  • 利用BootStrap弹出二级对话框的简单实现方法

    弹出二级对话框,即在对话框的基础上再弹出一个对话框.这对于CRM管理类系统来说应用场景很常见.看到网上有关于实现二级弹出框的方法,需要在一级对话框页面上添加不少css样式.其实,完全可以不用这么麻烦. 利用bootstrap实现二级对话框很简单,只需要在主页面上添加两个含有class="modal"的DIV标签.如下面代码: <!DOCTYPE html> <html> <head> <title></title> <m

  • 利用PHP fsockopen 模拟POST/GET传送数据的方法

    使用php可以模拟 post 和 get 传送数据到别的网页或站点 $arr=array( 'user'=>'test', 'password'=>'' ); sock_get($post_url,$arr); sock_post($post_url,$arr); //fsocket模拟get提交 function sock_get($url,$query=array()){ $query_str = http_build_query($query); $<span id="_

  • 利用Python自动监控网站并发送邮件告警的方法

    前言 因为有一些网站需要每日检查是否有问题,所以需要一个报警监控的机制,这个需要你指定你发送的邮箱和你接收的邮箱,就可以做到对网站自动监控了. 这里用的是python3.5 需要安装的插件: 1.smtplib:发邮件需要用到 2.pycurl:访问网站时会需要用到 3.linecache:在读取txt网站清单时需要用到 具体思路: python程序从txt里面批量读取到网站的信息,通过Curl.py模拟浏览器去访问网站,并且把访问的结果写入到以自己的网站名称-日期.txt格式的文件中记录;有几

  • 利用Fiddler对手机进行抓包的实现方法

    利用Fiddler对手机进行抓包的实现方法

    用Fiddler对手机进行抓包的设置如下: 1.处于同一个局域网下 2.PC端,打开Fiddler,设置: (1)打开Tools-Options (2)设置HTTPS (3)设置Connections (4)查看PC的局域网IP地址并记住 (5)重启Fiddler 3.手机端设置 (1)长按wifi图标进入wifi列表 (2)长按当前使用的wifi进入修改状态 (3)勾选"显示高级选项" (4)代理-选择"手动" (5)主机名填写PC的局域网IP (6)端口填写88

  • 利用JQuery直接调用asp.net后台的简单方法

    利用JQuery的$.ajax()可以很方便的调用asp.net的后台方法. [WebMethod]   命名空间 1.无参数的方法调用, 注意:1.方法一定要静态方法,而且要有[WebMethod]的声明 后台<C#>: using System.Web.Script.Services; [WebMethod] public static string SayHello() { return "Hello Ajax!"; } 前台<jQuery>: $(fun

随机推荐