降低Task.Factory.StartNew线程的优先级

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了降低Task.Factory.StartNew线程的优先级相关的知识,希望对你有一定的参考价值。

像下面这样的代码将启动一个新线程来完成这项工作。有什么方法可以控制该线程的优先级吗?

Task.Factory.StartNew(() => {
    // everything here will be executed in a new thread.
    // I want to set the priority of this thread to BelowNormal
});
答案

当你决定是否使用线程池时,这是“不要做”之一;-)

更多细节在这里:http://msdn.microsoft.com/en-us/library/0ka9477y.aspx

所以答案是“不,你不能为线程池中创建的线程指定特定的优先级”

至于一般的线索,我打赌你已经知道Thread.Priority财产

另一答案

正如其他人所提到的,您需要指定一个自定义调度程序来处理您的任务。不幸的是,没有合适的内置调度程序。

您可以使用Glenn链接到的ParallelExtensionsExtras,但如果您想要一些简单的东西可以直接粘贴到您的代码中,请尝试以下操作。使用这样:

Task.Factory.StartNew(() => {
    // everything here will be executed in a thread whose priority is BelowNormal
}, null, TaskCreationOptions.None, PriorityScheduler.BelowNormal);

代码:

public class PriorityScheduler : TaskScheduler
{
    public static PriorityScheduler AboveNormal = new PriorityScheduler(ThreadPriority.AboveNormal);
    public static PriorityScheduler BelowNormal = new PriorityScheduler(ThreadPriority.BelowNormal);
    public static PriorityScheduler Lowest = new PriorityScheduler(ThreadPriority.Lowest);

    private BlockingCollection<Task> _tasks = new BlockingCollection<Task>();
    private Thread[] _threads;
    private ThreadPriority _priority;
    private readonly int _maximumConcurrencyLevel = Math.Max(1, Environment.ProcessorCount);

    public PriorityScheduler(ThreadPriority priority)
    {
        _priority = priority;
    }

    public override int MaximumConcurrencyLevel
    {
        get { return _maximumConcurrencyLevel; }
    }

    protected override IEnumerable<Task> GetScheduledTasks()
    {
        return _tasks;
    }

    protected override void QueueTask(Task task)
    {
        _tasks.Add(task);

        if (_threads == null)
        {
            _threads = new Thread[_maximumConcurrencyLevel];
            for (int i = 0; i < _threads.Length; i++)
            {
                int local = i;
                _threads[i] = new Thread(() =>
                {
                    foreach (Task t in _tasks.GetConsumingEnumerable())
                        base.TryExecuteTask(t);
                });
                _threads[i].Name = string.Format("PriorityScheduler: ", i);
                _threads[i].Priority = _priority;
                _threads[i].IsBackground = true;
                _threads[i].Start();
            }
        }
    }

    protected override bool TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued)
    {
        return false; // we might not want to execute task that should schedule as high or low priority inline
    }
}

笔记:

  • 工作线程都是后台线程,因此不应使用此调度程序调度重要任务;只有在进程关闭时才能丢弃的那些
  • 改编自an implementation by Bnaya Eshet
  • 我不完全理解每一个覆盖;就像Bnaya选择MaximumConcurrencyLevelGetScheduledTasksTryExecuteTaskInline一样。
另一答案

可以在执行任务的实际方法内设置任务的线程优先级。但是,一旦完成以避免问题,不要忘记恢复优先级。

所以首先启动任务:

new TaskFactory().StartNew(StartTaskMethod);

然后设置线程优先级:

void StartTaskMethod()
{
    try
    {
        // Change the thread priority to the one required.
        Thread.CurrentThread.Priority = ThreadPriority.AboveNormal;

        // Execute the task logic.
        DoSomething();
    }
    finally
    {
        // Restore the thread default priority.
        Thread.CurrentThread.Priority = ThreadPriority.Normal;
    }
}

更改优先级时,请记住:Why *not* change the priority of a ThreadPool (or Task) thread?

另一答案

要使用Task设置优先级,请查看Stephen Toub中Microsoft专家this MSDN blog post描述的自定义任务调度程序。有关更多详细信息,请不要错过他在第一句中提到的前两个帖子的链接。

对于你的问题,听起来你可能想看看QueuedTaskScheduler

以上是关于降低Task.Factory.StartNew线程的优先级的主要内容,如果未能解决你的问题,请参考以下文章

Task.Factory.StartNew 测试

Task.Factory.StartNew 测试

Task.Factory.StartNew 和 Task.Run

尽管在线程池中有可用的线程,但Task.Factory.StartNew的启动时间很长

Task.Run 和Task.Factory.StartNew 区别

Parallel.ForEach 与 Task.Factory.StartNew