序列演員問電話

Question

假設我有以下演員：

class A extends Actor { 
    def receive = { 
     case Unlock => sender ! UnlockResponse (Boolean_code) 
     case Read => sender ! ReadResponse (somedata) 
     case Lock => sender ! LockResponse (Boolean_code) 
    } } 

我想write.a輔助方法，在那裏我可以打電話給開鎖，讀取和順序鎖，並從返回「somedata」在上一步（鎖定）完成後，方法調用方的ReadResponse已完成。

我喜歡理解方法，但是如何以更靈活的方式編寫它，例如，如果Unlock在第一步中返回UnlockResponse（true）時繼續讀取，但如果返回值爲UnlockResponse （假）？

Answer 1

正如我在我的評論說，只是用一個換理解，在其監護條件，就像這樣：

val result = 
    for{ 
    unlockResult <- (nActorRef ? Unlock).mapTo[UnlockResponse] 
    if unlockResult.result == true 
    readResult <- (anActorRef ? Read).mapTo[ReadResponse] 
    } yield readResult 

這種情況下，唯一的問題是，通過result代表的產生Future會當不符合警戒條件時失敗。如果這是你的問題，你想，也許已在Future包裝一個Option[ReadResult]代替，那麼你可以使用recover像這樣：

val result:Future[Option[ReadResult]] = 
    for{ 
    unlockResult <- (nActorRef ? Unlock).mapTo[UnlockResponse] 
    if unlockResult.result == true 
    readResult <- (anActorRef ? Read).mapTo[ReadResponse] 
    } yield Some(readResult) 

result.recover{case ex:NoSuchElementException => None} 

Answer 2

對於您可以使用Scala Promises API的順序邏輯：

val promise = Promise[ReadResponse]() 
val unlockFuture = anActorRef ? Unlock 
unlockFuture.map{ 
    case UnlockResponse (true) => promise.completeWith(anActorRef ? Read) 
    case UnlockResponse (false) => p.failure(new IllegalStateException) 
} 

，然後根據結果，你可以這樣做

p.future.onComplete { 
    case Success(somedata) => { 
     processData(somedata) 
     anActorRef ! Lock 
    } 
    case Failure(t) => logger.error(t) 
} 

用相同的順序效果更好的解決方案可能是通過Actor實現成爲/不成熟，並且stash，其中事務邏輯由演員本身而不是發送者處理。