阅读量:0
在C#中,使用TaskScheduler
类可以方便地管理和调度多个任务。以下是一个简单的示例,展示了如何使用TaskScheduler
来创建、调度和执行多个任务:
首先,确保已经安装了
System.Threading.Tasks
命名空间。如果没有安装,可以通过NuGet包管理器进行安装。创建一个继承自
TaskScheduler
的类,以便可以添加自定义逻辑。在这个示例中,我们将创建一个简单的MyTaskScheduler
类。
using System; using System.Collections.Generic; using System.Threading; using System.Threading.Tasks; public class MyTaskScheduler : TaskScheduler { private readonly List<Task> _tasks = new List<Task>(); protected override IEnumerable<Task> GetScheduledTasks() { return _tasks; } protected override void QueueTask(Task task) { _tasks.Add(task); base.QueueTask(task); } public void Start() { foreach (var task in _tasks) { Task.Run(() => task.Run()); } } }
在这个示例中,我们创建了一个MyTaskScheduler
类,它继承自TaskScheduler
。我们添加了一个_tasks
列表来存储调度任务,并重写了GetScheduledTasks
和QueueTask
方法以便访问这些任务。我们还添加了一个Start
方法,用于启动所有调度任务。
- 创建一个要执行的任务类。在这个示例中,我们将创建一个简单的
MyTask
类,它实现IRunnable
接口。
public interface IRunnable { void Run(); } public class MyTask : IRunnable { private readonly string _name; public MyTask(string name) { _name = name; } public void Run() { Console.WriteLine($"Starting task: {_name}"); Thread.Sleep(1000); // 模拟任务执行时间 Console.WriteLine($"Finished task: {_name}"); } }
在这个示例中,我们创建了一个MyTask
类,它实现IRunnable
接口。Run
方法用于执行任务逻辑。
- 使用
MyTaskScheduler
类调度和执行多个任务。
class Program { static void Main(string[] args) { var taskScheduler = new MyTaskScheduler(); var tasks = new List<IRunnable> { new MyTask("Task 1"), new MyTask("Task 2"), new MyTask("Task 3") }; foreach (var task in tasks) { var t = Task.Factory.StartNew(task, CancellationToken.None, TaskCreationOptions.None, taskScheduler); t.ContinueWith(_ => Console.WriteLine($"Task completed: {t.Result._name}")); } taskScheduler.Start(); } }
在这个示例中,我们创建了一个MyTaskScheduler
实例,并创建了一个IRunnable
任务列表。然后,我们遍历任务列表,为每个任务创建一个新的Task
实例,并将其添加到MyTaskScheduler
中。最后,我们调用taskScheduler.Start()
方法来启动所有调度任务。
这个示例展示了如何使用TaskScheduler
类来管理和调度多个任务。你可以根据需要扩展这个示例,以适应你的具体需求。