आवधिक निष्पादन को लागू करने के लिए एक स्कैला-विशिष्ट तरीका है?

Question

एकेए सेट अंतराल पर कुछ कर रहा है।

उदाहरण के लिए, मान लें कि मैं हर 60 सेकंड में एक निश्चित निर्देशिका को स्कैन करना चाहता हूं।

जावा में, मैं बहुत की तरह एक ScheduledExecutorService का प्रयोग करेंगे:

Executor pool = Executors.newScheduledThreadPool(10) 
pool.scheduleAtFixedRate(scanner, 0, 60, TimeUnit.SECONDS) 

और कहा कि ठीक काम करता है।

बात यह है कि, मुझे लगता है कि मैं अपने कार्यक्रम में स्कैला कलाकारों का उपयोग करने की कोशिश करना चाहता हूं, लेकिन मैं थोड़ा उलझन में हूं कि कलाकारों और जावा निष्पादकों को कैसे जोड़ना है, या वे होना चाहिए।

मुझे लगता है कि शायद मेरे पास एक साधारण धावक हो सकता है जो केवल एन सेकेंड में एक अभिनेता को एक संदेश भेजेगा - क्या यह समझ में आता है?

Answer 1

मुझे लगता है कि शायद मैं एक साधारण धावक जो केवल हर एन सेकंड एक अभिनेता के लिए एक संदेश भेजना होगा हो सकता था - - क्या इसका कोई मतलब है?

हां, और अभिनेताओं के लिए अक्का का उपयोग करने पर विचार करें। इसमें एक सरल एपीआई है, बेहतर प्रदर्शन है और इसमें बहुत सारी चीज़ें हैं।

Answer 2

आप Java एक के बजाय Scala Executor स्वयं को आजमा सकते हैं।

एक ऑब्जेक्ट जो java.lang.Runnable कार्यों को निष्पादित करता है निष्पादित करता है।
यह इंटरफ़ेस थ्रेड उपयोग, शेड्यूलिंग इत्यादि के विवरण सहित प्रत्येक कार्य को चलाने के तरीके के मैकेनिक्स से कार्य जमा करने का एक तरीका प्रदान करता है।
एक निष्पादक आमतौर पर धागे को स्पष्ट रूप से बनाने के बजाय उपयोग किया जाता है। उदाहरण के लिए, बल्कि कार्यों का एक सेट से प्रत्येक के लिए new Thread(new(RunnableTask())).start() लागू की तुलना में, आप उपयोग कर सकते हैं:

Executor executor = anExecutor; 
executor.execute(new RunnableTask1()); 
executor.execute(new RunnableTask2()); 
...