C#如何使用Task类解决线程的等待问题

目录
  • 使用Task类解决线程的等待问题
    • Task类
    • 用法
    • 示例
    • 小结
  • C#代码执行中等待10秒

使用Task类解决线程的等待问题

在任何的编程语言中，面对耗时任务时，我们都会有这样的需求：让任务执行一定时间，主任务进行等待，如果到时仍然完成不了，那么就不再等待。

比如一个常见的应用就是连接远程数据库，如果由于网络问题连接不上，那么只等待指定时间如3秒，然后就不再等待。

这样的代码如果自己写类来实现的话并不困难，然而实际上C#已经内置了Task类用于解决此问题。

Task类

Task是C#中专门用于接收任务的类，通过构造函数接收任务，使用start()方法启动。当任务启动以后，可以使用Task.WaitAll(Task[] tasks, int timeout) 等待所有任务完成后或时间到 timeout ms后再继续。

注：由于Task的构造函数接受的是Action委托，所以是没有返回值的。

用法

Task核心功能是代理一个方法，然后在启动，主线程可以指定等待时间，具体如以下代码所示。

// 1. 初始化任务
var t1 = new Task(() => {
        Thread.Sleep(2000);
        Console.WriteLine("Hello");
    });  
// 2. 启动任务    
t1.start();

// 3. 指定等等时间，单位为毫秒
Task.WaitAll(new Task[] { t1 }, 3000);  

示例

在本示例中，我们启动了一个简单的任务t1，会暂时2秒然后输出字符串“Hello”，然后主线程等待3000毫秒，代码如下所示：

void Test1()
{
    //定义一个任务，等待2秒后输出Hello 
    var t1 = new Task(() => {
        Thread.Sleep(2000);
        Console.WriteLine("Hello");
    });  
 
     // 以多线程方式启动任务，t1和当前线程是两个线程
    t1.Start(); 
    Console.WriteLine("t1 started.");

    //等待所有任务结束(这里只有t1)，程序会卡在这里。等待的时间为 3000 毫秒
    Console.WriteLine("waiting...");
    Task.WaitAll(new Task[] { t1 }, 3000);  
    Console.WriteLine("stop waiting.")

    // 判断t1任务是否完成
    if (!t1.IsCompleted)
        Console.WriteLine("Running...");
    Console.WriteLine("Task done.");
}            

void print(string msg)
{
    Console.WriteLine($"{DateTime.Now:HH:mm:ss.ffff} {msg}");
}

程序运行后输出以下结果：

14:51:54.2233 t1 started.
14:51:54.2457 waiting...
14:51:56.2456 Hello
14:51:56.2456 stop waiting.
14:51:56.2456 Task done.

可以看到，程序在等待后约2000毫秒，任务t1执行完成，输出 Hello，但是由于我们设置的等待时间是3000毫秒，所以主线程仍然在等待中。在经过了约3000毫秒后，程序停止等待，继续执行。在继续执行时，由于t1已经执行完成，所以没有输出继续执行的相关信息。

下面我们将上面的等待时间由3000毫秒改为1000毫秒，那么在执行以后结果如下所示：

14:48:36.9624 t1 started.
14:48:36.9848 waiting...
14:48:37.9755 stop waiting.
14:48:37.9755 t1 still running...
14:48:37.9755 Task done.
14:48:38.9860 Hello

由以上结果可见，程序在等待了约1000毫秒后，由于等待时间已经到了，就继续向前执行，此时 t1 并没有执行完成，所以会输出 “t1 still running…”。等主线程执行完以后，t1 最终执行完成，输出了Hello。

小结

由以上示例可见，Task能够很方便的启动一个任务，主线程也可以决定等待时间。

不过这里还有三点需要注意一下：

1）Task没有返回值；

2）主线程不能中止Task；

3）计时精度不高，有一定的误差。

基于以上问题，我们可以知道Task类合适用在一些对控制和计时精度要求不高的场合。

C#代码执行中等待10秒

//等待10秒
DateTime dt1 = DateTime.Now;
while ((DateTime.Now - dt1).TotalMilliseconds < 10000)
{
continue;
};

以上为个人经验，希望能给大家一个参考，也希望大家多多支持我们。

赞 (0)

相关推荐

  • C#多线程系列之线程等待

    C#多线程系列之线程等待

    目录 前言 volatile 关键字 三种常用等待 再说自旋和阻塞 SpinWait 结构 属性和方法 自旋示例 新的实现 SpinLock 结构 属性和方法 示例 等待性能对比 前言 volatile 关键字 volatile 关键字指示一个字段可以由多个同时执行的线程修改. 我们继续使用<C#多线程(3):原子操作>中的示例: static void Main(string[] args) { for (int i = 0; i < 5; i++) { new Thread(AddO

  • C# 并行和多线程编程——认识和使用Task

    C# 并行和多线程编程——认识和使用Task

    对于多线程,我们经常使用的是Thread.在我们了解Task之前,如果我们要使用多核的功能可能就会自己来开线程,然而这种线程模型在.net 4.0之后被一种称为基于"任务的编程模型"所冲击,因为task会比thread具有更小的性能开销,不过大家肯定会有疑惑,任务和线程到底有什么区别呢? 任务和线程的区别: 1.任务是架构在线程之上的,也就是说任务最终还是要抛给线程去执行. 2.任务跟线程不是一对一的关系,比如开10个任务并不是说会开10个线程,这一点任务有点类似线程池,但是任务相比线

  • C#多线程编程Task用法详解

    C#多线程编程Task用法详解

    目录 一.基本概念 Task优势 二.Task用法 创建任务 1.使用Task创建无返回值 2.使用Task.Run方法创建任务 3.使用Factory方式创建任务 4.创建带返回值的Task 三.常见方法 1.WaitAll() 2.WaitAny() 3.ContinueWhenAll() 4.ContinueWhenAny 5.ContinueWith 一.基本概念 Task优势 ThreadPool相比Thread来说具备了很多优势,但是ThreadPool却又存在一些使用上的不方便,例

  • C#如何使用Task类解决线程的等待问题

    目录 使用Task类解决线程的等待问题 Task类 用法 示例 小结 C#代码执行中等待10秒 使用Task类解决线程的等待问题 在任何的编程语言中,面对耗时任务时,我们都会有这样的需求:让任务执行一定时间,主任务进行等待,如果到时仍然完成不了,那么就不再等待. 比如一个常见的应用就是连接远程数据库,如果由于网络问题连接不上,那么只等待指定时间如3秒,然后就不再等待. 这样的代码如果自己写类来实现的话并不困难,然而实际上C#已经内置了Task类用于解决此问题. Task类 Task是C#中专门用

  • 如何测试Java类的线程安全性

    这篇文章主要介绍了如何测试Java类的线程安全性,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 线程安全性是Java等语言/平台中类的一个重要标准,在Java中,我们经常在线程之间共享对象.由于缺乏线程安全性而导致的问题很难调试,因为它们是偶发的,而且几乎不可能有目的地重现.如何测试对象以确保它们是线程安全的? 假如有一个内存书架 package com.mzc.common.thread; import java.util.Map; impo

  • Java使用线程同步解决线程安全问题详解

    Java使用线程同步解决线程安全问题详解

    第一种方法:同步代码块: 作用:把出现线程安全的核心代码上锁 原理:每次只能一个线程进入,执行完毕后自行解锁,其他线程才能进来执行 锁对象要求:理论上,锁对象只要对于当前同时执行的线程是同一个对象即可 缺点:会干扰其他无关线程的执行 所以,这种只是理论上的,了解即可,现实中并不会这样用 public class 多线程_4线程同步 { public static void main(String[] args) { //定义线程类,创建一个共享的账户对象 account a=new accoun

  • C#并行编程Task类用法介绍

    Task和ThreadPool的功能类似,可以用来创建一些轻量级的并行任务.对于将一个任务放进线程池 ThreadPool.QueueUserWorkItem(A); 这段代码用Task来实现的话,方式如下: Task.Factory.StartNew(A); 这两端代码的使用和实现的功能都十分相似.但和TheadPool相比,Task有着更多的功能,更加方便我们使用. 假如我们要创建三个任务,并等待它们完成.这个功能用TheadPool实现如下: using (ManualResetEvent

  • .Net并行库Task类介绍

    Task和ThreadPool的功能类似,可以用来创建一些轻量级的并行任务.对于将一个任务放进线程池 ThreadPool.QueueUserWorkItem(A); 这段代码用Task来实现的话,方式如下: Task.Create(A); 这两端代码的使用和实现的功能都十分相似.但和TheadPool相比,Task有着更多的功能,更加方便我们使用. Task.WaitAll()该函数的功能是等待多个任务等待任务完成,这在线程同步时经常需要用到. 假如我们要创建三个任务,并等待它们完成.这个功能

  • java多线程编程之使用thread类创建线程

    在Java中创建线程有两种方法:使用Thread类和使用Runnable接口.在使用Runnable接口时需要建立一个Thread实例.因此,无论是通过Thread类还是Runnable接口建立线程,都必须建立Thread类或它的子类的实例.Thread类的构造方法被重载了八次,构造方法如下: 复制代码 代码如下: public Thread( );public Thread(Runnable target);public Thread(String name);public Thread(Ru

  • java线程之用Thread类创建线程的方法

    在Java中创建线程有两种方法:使用Thread类和使用Runnable接口.在使用Runnable接口时需要建立一个Thread实例.因此,无论是通过Thread类还是Runnable接口建立线程,都必须建立Thread类或它的子类的实例.Thread类的构造方法被重载了八次,构造方法如下: 复制代码 代码如下: public Thread( ); public Thread(Runnable target); public Thread(String name); public Thread

  • Java 集合中的类关于线程安全

    Java集合中那些类是线程安全的 线程安全类 在集合框架中,有些类是线程安全的,这些都是jdk1.1中的出现的.在jdk1.2之后,就出现许许多多非线程安全的类. 下面是这些线程安全的同步的类: vector:就比arraylist多了个同步化机制(线程安全),因为效率较低,现在已经不太建议使用.在web应用中,特别是前台页面,往往效率(页面响应速度)是优先考虑的. statck:堆栈类,先进后出 hashtable:就比hashmap多了个线程安全 enumeration:枚举,相当于迭代器

  • C#通过Semaphore类控制线程队列的方法

    本文实例讲述了C#通过Semaphore类控制线程队列的方法.分享给大家供大家参考.具体实现方法如下: using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.IO; using System.Diagnostics; using System.Threading; using System.ComponentModel; using System.Col

  • Java继承Thread类创建线程类示例

    本文实例讲述了Java继承Thread类创建线程类.分享给大家供大家参考,具体如下: 一 点睛 通过继承Thread类创建线程并启动多线程的步骤: 1 定义Thread的子类,并重写该类的run()方法,该run()方法的方法体代表了线程需要完成的任务.因此run()方法称为线程执行体. 2 创建Thread子类的实例,即创建子线程对象. 3 调用线程对象的start()方法来启动该线程. 二 代码 // 通过继承Thread类来创建线程类 public class FirstThread ex

随机推荐