Akka Actors - 锁定单一资源请求

Question

我正在使用几个akka演员来监控我的系统,每个演员负责一个不同的组件.

一些演员操作不应该并行执行.所以我创建了一个持有锁(LockActor)的actor.一旦演员想要执行此类操作,他需要向LockActor请求批准,并且在获得批准之前他不能执行操作.

如果我想让代码变得简单,那么在请求的actor中我需要做类似的事情:

while (LockActor.isLockHold()) {
    // perform the operation
}

这当然打破了演员系统的整体设计......

所以我需要使用使代码有点复杂的消息:

1. Actor B需要将LockRequestMessage发送给LockActor
2. LockActor持有保存锁请求的队列
3. 如果可以锁定,LockActor会将LockApprovalMessage发送给队列中的第一个actor
4. 当actor B收到LockApprovalMessage(不一定立即)时,他需要执行发送LockRequestMessage时所需的特定操作(每个actor可以有几个需要锁的操作)

所以我的问题是 - 什么是最好的方式实现这样的事情没有打破演员系统的设计,但仍保持代码尽可能简单？

Answer 1

而不是使用单个actor获取锁定,为什么不只使用单个actor来完成工作？这是actor模型中的首选方式.

Answer 2

我在这里看到两种解决方案。

首先，您可以使用询问模式：

class MyActor extends Actor {

    def receive = {
        case Start: {
            val f = lockActor ? LockRequestMessage
            f onSuccess {
                case LockApprovalMessage => {
                    //todo: do your thing
                }
            }
        }
    }

}

请注意，ask 方法将创建另一个参与者，该参与者接收请求消息并完成 future - 有关更多详细信息，请参阅文档。

如果你不想使用ask模式，你可以很好地使用become-unbecome机制，如下所示：

class MyActor extends Actor {
    import context._

    def receive = {
        case Start: {
            lockActor ! LockRequestMessage
            become(waitForApproval)
        }
    }    

    def waitForApproval = {
        case LockApprovalMessage => {
            //todo: do your thing
        }
    }


}

您可以很好地在同一个接收函数中处理这两条消息，但您必须记录参与者在某个时刻所处的状态。“变得不合适”机制会为您完成这种干净的分离。

请注意，如果您使用锁来防止参与者改变某些共享资源，Akka 为此提供了一些更复杂的机制：

• 代理 - http://doc.akka.io/docs/akka/2.1.0-RC2/scala/agents.html
• 交易者 - http://doc.akka.io/docs/akka/2.1.0-RC2/scala/transactors.html

查看文档 - 它可能会显着简化您的实施。