脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → C#教程 → C#Task执行任务,等待任务完成

C#如何Task执行任务,等待任务完成

 更新时间：2022年06月09日 10:33:09   作者：熊思雨  
这篇文章主要介绍了C#如何Task执行任务，等待任务完成，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

Task执行任务,等待任务完成

代码：

//任务
Func<int> Funcs = () =>
{
    Console.WriteLine("任务开始");
    return 1 + 1;
};
 
//执行任务
Task<int> printRes = Task.Run(Funcs);
 
//等待任务完成
printRes.GetAwaiter().OnCompleted(() =>
{
    Console.WriteLine("异步执行结果：" + printRes.Result);        
});

运行：

任务开始
异步执行结果：2

C# Task任务队列

需求

众所周知，方法体内代码是从上往下执行的，在我们工作中经常会遇到一些需要延时执行，但又必须按顺序来执行的需求。这要怎么解决呢。微软官方提供的Task API就是专门来解决这个问题的。那么下面就开始吧。

基本的Task用法

新建一个Winfrom项目

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
 
namespace 线程2
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
 
        private void Form1_Load(object sender, EventArgs e)
        {
            Task task1 = new Task(() =>
            {
                Thread.Sleep(400);
                Console.WriteLine("task1");
            });
            Task task2 = new Task(() =>
            {
                Thread.Sleep(300);
                Console.WriteLine("task2");
            });
            Task task3 = new Task(() =>
            {
                Thread.Sleep(200);
                Console.WriteLine("task3");
            });
            Task task4 = new Task(() =>
            {
                Thread.Sleep(100);
                Console.WriteLine("task4");
            });
            task1.Start();
            task2.Start();
            task3.Start();
            task4.Start();
        }
    }
}

运行:

由于各个任务内部延时不同，最先执行的Task1，反而最后一个执行完，如果既要做延时操作，又要求从任务按顺序执行，要怎么解决呢？

让Task任务按顺序执行

修改代码：

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
 
namespace 线程2
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
 
        private List<Task> TaskList = new List<Task>();
 
        private void Form1_Load(object sender, EventArgs e)
        {
            Task task1 = new Task(() =>
            {
                Thread.Sleep(400);
                Console.WriteLine("task1");
            });
            Task task2 = new Task(() =>
            {
                Thread.Sleep(300);
                Console.WriteLine("task2");
            });
            Task task3 = new Task(() =>
            {
                Thread.Sleep(200);
                Console.WriteLine("task3");
            });
            Task task4 = new Task(() =>
            {
                Thread.Sleep(100);
                Console.WriteLine("task4");
            });
 
            TaskList.Add(task1);
            TaskList.Add(task2);
            TaskList.Add(task3);
            TaskList.Add(task4);
 
            foreach (Task task in TaskList)
            {
                task.Start();
                task.Wait();
            }
        }
    }
}

运行：

用上面的方法虽然有效，你可以看看，点击界面的时候，界面处鼠标指针会一直转圈，导致winfrom界面卡住，无法操作，这是因为使用Thread.Sleep 导致主线程阻塞，下面就来解决UI界面卡死的问题。

使用异步委托解决UI界面卡死问题

代码：

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
 
namespace 线程2
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();
        }
 
 
        private List<Task> TaskList = new List<Task>();
 
 
        private void Button_Calculate_Click(object sender, EventArgs e)
        {
            Task task1 = new Task(async () =>
            {
                await Task.Delay(TimeSpan.FromSeconds(4));
                Console.WriteLine("task1");
            });
            Task task2 = new Task(async () =>
            {
                await Task.Delay(TimeSpan.FromSeconds(3));
                Console.WriteLine("task2");
            });
            Task task3 = new Task(async () =>
            {
                await Task.Delay(TimeSpan.FromSeconds(2));
                Console.WriteLine("task3");
            });
            Task task4 = new Task(async () =>
            {
                await Task.Delay(TimeSpan.FromSeconds(1));
                Console.WriteLine("task4");
            });
 
            TaskList.Add(task1);
            TaskList.Add(task2);
            TaskList.Add(task3);
            TaskList.Add(task4);
 
            foreach (Task task in TaskList)
            {
                task.Start();
                task.Wait();
            }
        }
    }
}

运行：

用异步方式虽然界面不会卡住，但另一个问题来了，task.wait()方法似乎没有效果。里面的任务队列依然没有按顺序来执行。那么如何即使用异步执行，也不阻塞主线程，而且要任务按顺序来执行呢？

异步任务队列按顺序执行

代码：

private void Test()
{
    Task.Run(() =>
    {
        Task t1 = new Task(() => {
            Thread.Sleep(2000);
            Console.WriteLine("t1");
            num = 1;
        });
        t1.Start();
        t1.Wait();
        Task t2 = new Task(() => {
            Thread.Sleep(1000);
            Console.WriteLine("t2");
            num = 3;
        });
        t2.Start();
        t2.Wait();
        Console.WriteLine("线程执行完毕");
    });
}

运行：

效果是实现了，代码看起来好搓啊，强迫症都犯了，没关系，可以使用更优雅的写法：

private async void Test()
{
    await Task.Run(async () =>
    {
        await Task.Delay(4000);
        Trace.WriteLine("第1个线程执行");
    });
    await Task.Run(async () =>
    {
        await Task.Delay(3000);
        Trace.WriteLine("第2个线程执行");
    });
    await Task.Run(async () =>
    {
        await Task.Delay(2000);
        Trace.WriteLine("第3个线程执行");
    });
}

运行：

到此为止，功能就实现了，这个需求在Unity3d中使用协程很简单的几句就可以搞定，但在Winfrom等项目的开发中，确实有点繁琐。

封装任务队列

下面的代码我不认为是一个很好的写法，需要添加任务后，还得手动去调用，如果能添加到任务队列就不管了，让其自己自动按顺序来执行任务，岂不是更好，读者如果有兴趣自己去完善这个猜想。另外，在游戏开发中，比如RGP项目中，有专门的任务系统，它和我这个帖子的概念不能混为一谈，RPG任务系统更多的偏向数据的存取，来获取任务的完成状态。

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
 
namespace Utils
{
    public class TaskQueue
    {
        /// <summary>
        /// 任务列表
        /// </summary>
        private List<Task> TaskList = null;
        /// <summary>
        /// 是否在执行任务中
        /// </summary>
        private bool isPerformTask = false;
        /// <summary>
        /// 执行完任务的回调
        /// </summary>
        public Action CallBack = null;
 
 
        private static TaskQueue _instance = null;
        public static TaskQueue Instance
        {
            get
            {
                if (_instance == null)
                    _instance = new TaskQueue();
                return _instance;
            }
        }
 
        /// <summary>
        /// 添加任务
        /// </summary>
        /// <param name="task"></param>
        public void AddTask(Task task)
        {
            if (isPerformTask)
            {
                Console.WriteLine("[TaskQueue]任务正在执行中，此时不能做赋值操作");
                return;
            }
 
            if (task != null)
            {
                TaskList.Add(task);
            }
        }
 
        /// <summary>
        /// 执行任务
        /// </summary>
        public void PerformTask()
        {
            if (isPerformTask)
            {
                Console.WriteLine("[TaskQueue]任务正在执行中，不可重复调用");
                return;
            }
            if (TaskList == null || TaskList.Count == 0)
            {
                Console.WriteLine("[TaskQueue]任务列表为空");
                return;
            }         
 
            Task.Run(() =>
            {
                isPerformTask = true;
 
                foreach (Task item in TaskList)
                {
                    item.Start();
                    item.Wait();
                }
 
                TaskList.Clear();
                isPerformTask = false;
 
                if (CallBack != null) CallBack();
            });
        }
 
        private TaskQueue()
        {
            TaskList = new List<Task>();
        }
    }
}

调用：

Task task1 = new Task(() =>
{
    Thread.Sleep(1000);
    Console.WriteLine("t1");
});
Task task2 = new Task(() =>
{
    Thread.Sleep(2000);
    Console.WriteLine("t2");
});
Task task3 = new Task(() =>
{
    Console.WriteLine("t3");
});
Action callback = () =>
{
    Console.WriteLine("所有任务执行完成");
};
TaskQueue.Instance.AddTask(task1);
TaskQueue.Instance.AddTask(task2);
TaskQueue.Instance.AddTask(task3);
TaskQueue.Instance.CallBack = callback;
TaskQueue.Instance.PerformTask();

运行：

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

您可能感兴趣的文章:

相关文章

  • 基于C#实现PDF按页分割文件和分页合并

    基于C#实现PDF按页分割文件和分页合并

    iTextSharp 是一个开源的 PDF 处理库,用于在 C# 程序中创建、编辑和处理 PDF 文件,本文将使用iTextSharp实现C# PDF分割与合并,感兴趣的可以了解下
    2025-03-03
  • C#基础语法：Base关键字学习笔记

    C#基础语法：Base关键字学习笔记

    这篇文章主要介绍了C#基础语法：Base关键字学习笔记,本文讲解了它的一些基础知识以及测试代码,需要的朋友可以参考下
    2015-06-06
  • Winform学生信息管理系统各子窗体剖析（3）

    Winform学生信息管理系统各子窗体剖析（3）

    这篇文章主要针对Winform学生信息管理系统各子窗体进行剖析,感兴趣的小伙伴们可以参考一下
    2016-05-05
  • C#实现功能强大的中国农历日历操作类

    C#实现功能强大的中国农历日历操作类

    这篇文章主要介绍了C#实现功能强大的中国农历日历操作类,实例分析了C#操作时间及字符串的技巧,非常具有实用价值,需要的朋友可以参考下
    2015-03-03
  • WPF实现2048小游戏

    WPF实现2048小游戏

    这篇文章主要为大家详细介绍了WPF实现2048小游戏，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2018-02-02
  • C#的TimeSpan案例详解

    C#的TimeSpan案例详解

    这篇文章主要介绍了C#的TimeSpan案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-08-08
  • C# 中 “$” 符号的作用以及用法详解

    C# 中 “$” 符号的作用以及用法详解

    这篇文章主要介绍了C# 中 “$” 符号的作用以及用法，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-06-06
  • C#获得程序的根目录以及判断文件是否存在的实例讲解

    C#获得程序的根目录以及判断文件是否存在的实例讲解

    今天小编大家分享一篇C#获得程序的根目录以及判断文件是否存在的实例讲解，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2019-06-06
  • C#中多维数组[,]和交错数组[][]的区别

    C#中多维数组[,]和交错数组[][]的区别

    这篇文章介绍了C#中多维数组[,]和交错数组[][]的区别，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
    2022-01-01
  • C#读取写入文件的3种方式示例代码

    C#读取写入文件的3种方式示例代码

    最近操作文件频繁,所以这篇文章主要给大家介绍了关于C#读取写入文件的3种方式,文中通过实例代码介绍的非常详细,对大家学习或者使用C#具有一定的参考学习价值,需要的朋友可以参考下
    2022-06-06

最新评论