91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

C#怎么實現TaskScheduler任務調度器

c#
小億
147
2024-01-23 10:42:15
欄目: 編程語言

在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方法將任務提交到自定義任務調度器中。每個任務都會打印出它們的任務編號和線程編號。

請注意,任務調度器是按順序調度任務的,因此任務可能會在不同的線程上執行,但它們的順序是保證的。

希望能幫助到你!

0
桂平市| 宁化县| 永安市| 廊坊市| 鞍山市| 新河县| 体育| 卫辉市| 桦甸市| 雷波县| 蒙城县| 白河县| 锡林郭勒盟| 汨罗市| 台中市| 安徽省| 宁乡县| 紫金县| 丘北县| 杂多县| 岚皋县| 定边县| 潜江市| 兴业县| 汉寿县| 铅山县| 汾西县| 久治县| 宁南县| 新干县| 高尔夫| 始兴县| 灵寿县| 大新县| 定襄县| 静乐县| 云浮市| 赤城县| 奉新县| 芒康县| 邵阳县|