सरल स्काला अभिनेता सवाल

Question

मुझे यकीन है कि यह एक बहुत ही सरल सवाल है, लेकिन मैं इसे चारों ओर मेरे सिर नहीं मिल सकता है कहने के लिए शर्मिंदा हूं:

मैं स्काला में मूल्यों की एक सूची है। मैं समांतर में प्रत्येक मान के साथ कुछ (बाहरी) कॉल करने के लिए उपयोग कलाकारों का उपयोग करना चाहता हूं।

मैं तब तक इंतजार करना चाहता हूं जब तक कि सभी मान संसाधित नहीं हो जाते हैं, और फिर आगे बढ़ें।

कोई साझा मूल्य संशोधित नहीं किया जा रहा है।

कोई भी सलाह दे सकता है?

धन्यवाद

Answer 1

वहाँ स्काला में एक अभिनेता-का उपयोग कर वर्ग के लिए ठीक किया जाता है इस तरह की समस्या: वायदा। इस समस्या को हल किया जाएगा:

// This assigns futures that will execute in parallel 
// In the example, the computation is performed by the "process" function 
val tasks = list map (value => scala.actors.Futures.future { process(value) }) 

// The result of a future may be extracted with the apply() method, which 
// will block if the result is not ready. 
// Since we do want to block until all results are ready, we can call apply() 
// directly instead of using a method such as Futures.awaitAll() 
val results = tasks map (future => future.apply()) 

वहां आप जाते हैं। बस कि।

Answer 2

कार्यकर्ताओं बनाएँ और उन्हें !! का उपयोग कर भविष्य के लिए पूछना; फिर परिणामों को पढ़ें (जिसे गणना की जाएगी और वे तैयार होने के समानांतर में आते हैं; फिर आप उनका उपयोग कर सकते हैं)। उदाहरण के लिए:

object Example { 
    import scala.actors._ 
    class Worker extends Actor { 
    def act() { Actor.loop { react { 
     case s: String => reply(s.length) 
     case _ => exit() 
    }}} 
    } 
    def main(args: Array[String]) { 
    val arguments = args.toList 
    val workers = arguments.map(_ => (new Worker).start) 
    val futures = for ((w,a) <- workers zip arguments) yield w !! a 
    val results = futures.map(f => f() match { 
     case i: Int => i 
     case _ => throw new Exception("Whoops--didn't expect to get that!") 
    }) 
    println(results) 
    workers.foreach(_ ! None) 
    } 
} 

यह एक बहुत ही सस्ती गणना करता है - एक स्ट्रिंग की लंबाई की गणना - लेकिन आप कुछ देखते महंगा यकीन है कि यह वास्तव में समानांतर में होता है (आखिरी बात की है कि मामला बनाने के लिए रख सकते हैं अधिनियम के साथ जवाब ब्लॉक होना चाहिए)। ध्यान दें कि हम कार्यकर्ता को खुद को बंद करने के लिए एक मामला भी शामिल करते हैं, और जब हम सब कुछ पूरा हो जाते हैं, तो हम श्रमिकों को बंद करने के लिए कहते हैं। (इस मामले में, किसी भी गैर-स्ट्रिंग कार्यकर्ता बंद हो जाता है।)

और हम यकीन है कि यह काम करता है बनाने के लिए इस बाहर की कोशिश कर सकते हैं:

scala> Example.main(Array("This","is","a","test")) 
List(4, 2, 1, 4)