C#でTaskSchedulerタスクスケジューラーを実装する方法は何ですか？

1年 ago
芽依, 雨夜
1 minute

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メソッドを使用してそれらをカスタムタスクスケジューラーに送信しています。各タスクは、そのタスク番号とスレッド番号を出力します。

注意してください、タスクスケジューラは順番にタスクをスケジュールしているため、タスクは異なるスレッドで実行されることがありますが、その順序は保証されています。

あなたのお役に立てれば嬉しいです！

bannerAds