Esiste un modo specifico per Scala per implementare l'esecuzione periodica?

Question

AKA fa qualcosa a intervalli impostati.

Ad esempio, supponiamo di voler eseguire la scansione di una determinata directory ogni 60 secondi.

In Java, vorrei utilizzare un ScheduledExecutorService in questo modo:

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

e che funziona bene.

Il fatto è che sto pensando di provare a utilizzare gli attori di Scala nel mio programma, ma sono un po 'confuso su come combinare attori e esecutori Java, o se dovrebbero essere.

Suppongo che potrei avere un semplice corridore che invii semplicemente un messaggio a un attore ogni N secondi - ha senso?

Answer 1

Credo che forse avrei potuto avere un semplice corridore che semplicemente inviare un messaggio a un attore ogni n secondi - - Ha senso?

Sì, e prendere in considerazione l'utilizzo di Akka per gli attori a proposito. Ha un'API più semplice, prestazioni migliori e un sacco di cose gustosissime.

Answer 2

Si potrebbe provare lo stesso Scala Executor, anziché quello Java.

Un oggetto che esegue le attività inviate java.lang.Runnable.
Questa interfaccia fornisce un modo per disaccoppiare l'invio di attività dai meccanismi di esecuzione di ciascuna attività, inclusi i dettagli sull'utilizzo del thread, la pianificazione, ecc.
Un Executor viene normalmente utilizzato anziché creare esplicitamente i thread. Ad esempio, invece di invocare new Thread(new(RunnableTask())).start() per ciascuno di un insieme di attività, è possibile utilizzare:

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