强制任务继续当前线程？

我正在为.NET建立一个AKKA框架的端口(现在不要太认真了,现在这是一个周末黑客的演员部分)

我对其中的"未来"支持存在一些问题.在Java/Scala Akka中,期货将与Await电话同步等待.很像.NET Task.Wait()

我的目标是支持真正的异步等待.它现在可以工作,但是在我当前的解决方案中,继续在错误的线程上执行.

这是将消息传递给我的一个包含未来await块的actor的结果.如您所见,actor总是在同一个线程上执行,而await块在随机线程池线程上执行.

actor thread: 6
await thread 10
actor thread: 6
await thread 12
actor thread: 6
actor thread: 6
await thread 13
...

actor使用DataFlow获取消息BufferBlock 或者更确切地说,我在缓冲区块上使用RX来订阅消息.它配置如下:

var messages = new BufferBlock()
{
        BoundedCapacity = 100,
        TaskScheduler = TaskScheduler.Default,
};
messages.AsObservable().Subscribe(this);

到现在为止还挺好.

但是,当我等待未来的结果时.像这样:

protected override void OnReceive(IMessage message)
{
    ....

    var result = await Ask(logger, m);
    // This is not executed on the same thread as the above code
    result.Match()  
       .With(t => {
       Console.WriteLine("await thread {0}",
          System.Threading.Thread.CurrentThread.GetHashCode());
        })
       .Default(_ => Console.WriteLine("Unknown message"));
     ...

我知道这是异步等待的正常行为,但我必须确保只有一个线程可以访问我的actor.

我不希望未来同步运行,我想像正常一样运行异步,但我希望继续运行在与消息处理器/ actor相同的线程上.

我的未来支持代码如下所示:

public Task Ask(ActorRef actor, IMessage message)
{
    TaskCompletionSource result = 
        new TaskCompletionSource();
    var future = Context.ActorOf(name : Guid.NewGuid().ToString());

    // once this object gets a response, 
    // we set the result for the task completion source
    var futureActorRef = new FutureActorRef(result);            
    future.Tell(new SetRespondTo(), futureActorRef); 
    actor.Tell(message, future); 
    return result.Task;
}

任何想法我可以做什么来强制继续在启动上述代码的同一个线程上运行？