गैर-अभिनेता कोड

Question

का जवाब देते समय अक्का ने रैपिंग भविष्य से परहेज किया, मैं अक्का 2 के साथ एक छोटा कैशिंग अभिनेता बना रहा हूं और अभिनेता को ब्लॉक नहीं करने के लिए मैं वायदा के अंदर सभी गणना करता हूं। हालांकि एक समस्या यह है कि इस अभिनेता को ऐसे कोड के साथ बातचीत करने की भी आवश्यकता है जो खुद अभिनेता में नहीं है, ताकि मुझे मूल्य प्राप्त करने के लिए "पूछने" पैटर्न का उपयोग करने की आवश्यकता हो।

मेरा सवाल है, मैं पूछताछ पैटर्न का उपयोग करते समय किसी अन्य भविष्य के अंदर अपनी गणना के भविष्य को लपेटने से कैसे बचूं?

उदाहरण के लिए

val f = myCache ? GetOrCalc("myKey", myCalculation) // this will be a Future[Future[...]] but I would like a Future[...] 

// meanwhile, inside the actor 
def receive = { 
    case GetOrCalc(key, calculation) => 
     if (keyNotExists) sender ! Future { calculation() } // calculation() is long-running 
     else sender ! cacheMap(key) 
} 

आदर्श रूप में मैं Future.pipeTo समारोह इस्तेमाल कर सकते हैं लेकिन मुझे डर है इस गैर अभिनेता कोड के लिए एक "प्रतिक्रिया" के रूप में गिना नहीं प्राप्त करता हूँ

Answer 1

यह समाधान है:

val f = myCache ? GetOrCalc("myKey", myCalculation) 

def receive = { 
    case GetOrCalc(key, calculation) => 
     if (keyNotExists) Future { calculation() } pipeTo sender 
     else sender ! cacheMap(key) 
} 

संदेश-और-प्राप्त-फ्यूचर "> http://doc.akka.io/docs/akka/2.0.3/scala/actors.html# Ask_Send-and-Receive-future

Answer 2

को onComplete जोड़े गणना भविष्य।

def receive = { 
    case GetOrCalc(key, calculation) => 
     if (keyNotExists) // calculation() is long-running 
      Future { calculation() } onComplete { 
       case Right(result) => result match { 
         case Some(value) => sender ! value 
         case None => sender ! Status.Failure(new Exception("Cannot find the value")) 
        } 
       case Left(ex) => 
        sender ! Status.Failure(ex) 

      } 
     else sender ! cacheMap(key) 
} 

और कैश सिस्टम बनाने के लिए अक्का का उपयोग करने के बारे में एक लेख है। http://letitcrash.com/post/30509298968/case-study-an-auto-updating-cache-using-actors