任务继续已安排到非线程池线程.为什么?

本文关键字:线程 为什么 继续 任务 | 更新日期: 2023-09-27 17:57:45

在控制台应用程序中,我确实创建了自己的线程来实现工作队列。此外,我已经为这个唯一的线程实现了我自己的SynchronizationContext。

当我等待来自主线程的任务时,突然在我的工作线程上安排了继续(我例程的剩余部分),这是错误的,因为我不希望我的线程被用作随机任务的线程池线程。

只有在使用Mono运行代码时,我才会遇到这种行为。

下面是一个代码,它再现了mono上的问题(在macosx和linux系统上测试):

using System;
using System.Collections.Generic;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
class Program
{
    static void Main( string[] args )
    {
        Foo();
        Console.ReadLine();
    }

    async static void Foo()
    {
        Console.WriteLine( "{0}: current thread ID={1}; scheduler={2}; context={3};",
            "   Main BEFORE awaiting",
            Thread.CurrentThread.ManagedThreadId, 
            TaskScheduler.Current.Id,
            SynchronizationContext.Current != null );
            // MONO Output: Main BEFORE awaiting: current thread ID=1; scheduler=1; context=False;
        WorkQueue queue = new WorkQueue();
        // !!! 
        // I do expect that current context which is null will be captured for continuation.
        // !!!
        await queue.Enqueue();
        // !!!
        // As we can see our custom context was captured to continue with this part of code.
        // 
        Console.WriteLine( "{0}: current thread ID={1}; scheduler={2}; context={3};",
            "   Main AFTER awaiting",
            Thread.CurrentThread.ManagedThreadId,
            TaskScheduler.Current.Id,
            SynchronizationContext.Current != null );
        // MONO Output: Main AFTER awaiting: current thread ID=4; scheduler=1; context=True;
    }
}
// Custom context which does nothing but enqueues fake tasks to the queue.
//
class WorkQueueSyncContext : SynchronizationContext
{
    readonly WorkQueue queue;
    public WorkQueueSyncContext( WorkQueue queue )
    {
        this.queue = queue;
    }
    public override void Post( SendOrPostCallback d, object state )
    {
    }
    public override void Send( SendOrPostCallback d, object state )
    {
        queue.Enqueue().Wait();
    }
}
// The queue
//
class WorkQueue
{
    readonly Thread thread;
    class WorkQueueItem
    {
        public TaskCompletionSource<object> Completion
        {
            get;
            set;
        }
    }
    BlockingCollection<WorkQueueItem> queue = new BlockingCollection<WorkQueueItem>();

    public WorkQueue()
    {
        thread = new Thread( new ThreadStart( Run ) );
        thread.Start();
    }
    private void Run()
    {
        // Set ower own SynchronizationContext.
        //
        SynchronizationContext.SetSynchronizationContext( new WorkQueueSyncContext( this ) );
        Console.WriteLine( "{0}: current thread ID={1}; scheduler={2}; context={3};",
            "   WorkQueue START",
            Thread.CurrentThread.ManagedThreadId,
            TaskScheduler.Current.Id,
            SynchronizationContext.Current != null );
        // MONO Output: current thread ID=4; scheduler=1; context=True;
        // Working loop.
        //
        while ( true )
        {
            WorkQueueItem item = queue.Take();
            Console.WriteLine( "{0}: current thread ID={1}; scheduler={2}; context={3};",
                "   WorkQueue DOING TASK",
                Thread.CurrentThread.ManagedThreadId,
                TaskScheduler.Current.Id,
                SynchronizationContext.Current != null );
            // MONO Output: current thread ID=4; scheduler=1; context=True;
            // Completed the task :)
            //
            item.Completion.SetResult( true );
        }
    }
    public Task<object> Enqueue()
    {
        TaskCompletionSource<object> completion = new TaskCompletionSource<object>();
        queue.Add( new WorkQueueItem() { Completion = completion } );
        return completion.Task;
    }
}

所以,这里是MONO输出:

   Main BEFORE awaiting: current thread ID=1; scheduler=1; context=False;
   WorkQueue START: current thread ID=3; scheduler=1; context=True;
   WorkQueue DOING TASK: current thread ID=3; scheduler=1; context=True;
   Main AFTER awaiting: current thread ID=3; scheduler=1; context=True;

这是Windows的输出:

   Main BEFORE awaiting: current thread ID=10; scheduler=1; context=False;
   WorkQueue START: current thread ID=11; scheduler=1; context=True;
   WorkQueue DOING TASK: current thread ID=11; scheduler=1; context=True;
   Main AFTER awaiting: current thread ID=6; scheduler=1; context=False;

请注意(最后一行)上下文捕获的不同之处。

编辑:

Mono 3.4.0不可复制,因此在旧版本(至少3.2.6)中似乎是一个错误;

任务继续已安排到非线程池线程.为什么?

我认为您在Mono运行时中发现了一个错误。await之后的延续不应该发生在同步上下文与TaskAwaiterawait点捕获的同步上下文不同的线程上。

以下情况是可能的:

  1. 原始线程和完成线程都具有相同的同步上下文。延续可以是内联的(在完成线程上同步执行)
  2. 原始线程和完成线程都没有同步上下文(SynchronizationContext.Current == null)。延续仍然可以内联
  3. 在任何其他组合中,continuation都不能内联

所谓"可能是内联的",我的意思是不需要也不保证是这样(它仍然可以使用TaskScheduler.CurrentTaskScheduler.FromCurrentSynchronizationContext进行异步执行)。尽管如此,在目前微软对TPL的实现下,它确实为条件#1和#2内联了。

然而,对于#3,它不能内联,这是由常识决定的。请随时向Xamarin报告错误。首先尝试最新的Mono构建,看看问题是否仍然存在。