使用actor的可中断循环的模式

Question

我正在设计一个从无尽流中消耗项目的actor，并且需要一种方法来控制何时启动和停止使用消息。有没有一种通过演员来实现这种可中断循环的通用模式？我正在考虑让我的演员发送消息给自己。类似于（伪斯卡拉）：

class Interruptible extends Actor { 
    val stream: Stream 
    val running: boolean 

    def receive = { 
    case "start" => { 
     running = true 
     consumeItem 
    } 

    case "stop" => { 
     running = false 
    } 

    case "consumeNext" => consumeItem 
    } 

    def consumeItem { 
    if (running) { 
     stream.getItem 
     this ! "consumeNext" 
    } 
    } 
} 

这是关于事情的最佳方式吗？

谢谢！

Answer 1

也许像这样编码：

class Interruptible extends Actor { 
    val stream: Stream 

    def inactive: Receive = { // This is the behavior when inactive 
    case "start" => 
     self become active 
    } 

    def active: Receive = { // This is the behavior when it's active 
    case "stop" => 
     self become inactive 
    case "next" => 
     doSomethingWith(stream.getItem) 
     self ! "next" 
    } 

    def receive = inactive // Start out as inactive 
} 

干杯，