कलाकारों का उपयोग कर इंटरप्टिबल लूप के लिए पैटर्न

Question

मैं एक ऐसे अभिनेता को डिजाइन कर रहा हूं जो अंतहीन धारा से वस्तुओं का उपभोग करता है, और इसे शुरू करने पर नियंत्रण करने के तरीके की आवश्यकता होती है और संदेशों का उपयोग बंद कर देती है। अभिनेताओं के साथ इस तरह के अंतःस्थापित loops को लागू करने के लिए एक आम पैटर्न है? मैं सिर्फ अपने अभिनेता को संदेश भेजने के बारे में सोच रहा था। जैसे (छद्म स्काला) कुछ:

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 
} 

चीयर्स,