我在“未来”的支持中遇到一些问题.
在Java / Scala Akka中,期待与Await电话同步等待.
很像.NET Task.Wait()@H_404_5@

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

这是将消息传递给我的一个包含等待未来块的演员的结果.
正如你所看到的,演员总是在同一个线程上执行,而等待块在随机线程池线程上执行.@H_404_5@

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

演员使用DataFlow BufferBlock< Message>获取消息.
或者,我使用RX缓冲区来订阅消息.
它是这样配置的：@H_404_5@

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

到现在为止还挺好.@H_404_5@

但是,当我等待未来的结果.
像这样：@H_404_5@

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<SomeMessage>(t => {
       Console.WriteLine("await thread {0}",System.Threading.Thread.CurrentThread.GetHashCode());
        })
       .Default(_ => Console.WriteLine("Unknown message"));
     ...

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

我不希望将来能够同步运行,我想象正常一样运行异步,但是我希望继续在与消息处理器/ actor相同的线程上运行.@H_404_5@

我的未来支持代码如下所示：@H_404_5@

public Task<IMessage> Ask(ActorRef actor,IMessage message)
{
    TaskCompletionSource<IMessage> result = 
        new TaskCompletionSource<IMessage>();
    var future = Context.ActorOf<FutureActor>(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;
}

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