在C#中,可以使用System.Threading.Tasks.TaskScheduler
類來實現任務調度器。下面是一個示例代碼,展示了如何創建和調度任務。
首先,我們需要創建一個繼承自TaskScheduler
的自定義任務調度器類。在該類中,我們需要重寫QueueTask
方法來將任務添加到任務隊列,并且重寫TryExecuteTaskInline
方法來執行任務。
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
public class CustomTaskScheduler : TaskScheduler
{
private BlockingCollection<Task> taskQueue = new BlockingCollection<Task>();
private Thread schedulerThread;
public CustomTaskScheduler()
{
schedulerThread = new Thread(RunScheduler);
schedulerThread.Start();
}
protected override IEnumerable<Task> GetScheduledTasks()
{
return taskQueue.ToArray();
}
protected override void QueueTask(Task task)
{
taskQueue.Add(task);
}
protected override bool TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued)
{
if (Thread.CurrentThread == schedulerThread)
{
return TryExecuteTask(task);
}
else
{
return false;
}
}
private void RunScheduler()
{
foreach (var task in taskQueue.GetConsumingEnumerable())
{
TryExecuteTask(task);
}
}
}
接下來,我們可以使用自定義任務調度器來創建和調度任務。在下面的示例中,我們創建了10個任務,并且使用Task.Factory.StartNew
方法將任務提交到自定義任務調度器中。
using System;
using System.Threading.Tasks;
class Program
{
static void Main()
{
CustomTaskScheduler scheduler = new CustomTaskScheduler();
for (int i = 0; i < 10; i++)
{
int taskNumber = i + 1;
Task.Factory.StartNew(() => DoWork(taskNumber), CancellationToken.None, TaskCreationOptions.None, scheduler);
}
Console.ReadKey();
}
static void DoWork(int taskNumber)
{
Console.WriteLine("Task {0} is executing on thread {1}", taskNumber, Thread.CurrentThread.ManagedThreadId);
}
}
在上面的代碼中,我們創建了10個任務,并且使用Task.Factory.StartNew
方法將任務提交到自定義任務調度器中。每個任務都會打印出它們的任務編號和線程編號。
請注意,任務調度器是按順序調度任務的,因此任務可能會在不同的線程上執行,但它們的順序是保證的。
希望能幫助到你!