Будущее/обещание без ожидания результата? Обратный модуль

Question

У меня есть вопрос о scala's Future.

В настоящее время у меня есть программа, которая проходит через каталог и проверяет наличие документа. Если есть файл, программа должна преобразовать эти файлы в «.pdf»

Мой код выглядит следующим образом (это псевдокод):

for(file <- directory) { 
    if(timestamp > filetimestamp) { 
    Future { 
    // do a convert job that returns UNIT 
    } 
    } 
} 

Является ли это правильный код или мне нужно ждать возвращаемое значение?

Есть ли другие альтернативы, которые столь же легки, как и фьючерсы?

Answer 1

Для преобразования внутри Future просто используйте map и flatMap. Фактические операции выполняются асинхронно, когда обратные вызовы завершены, но они безопасны по типу.

import scala.concurrent.Future 
import scala.concurrent.ExecutionContext.Implicits.global 

for(file <- directory) { 
if(timestamp > filetimestamp) { 
    val future = Future { 
    // do a convert job that returns UNIT 
    } map { 
    file => // whatever you want. 
    } 
} 

Answer 2

Да, это действительно. Все созданные вами Future s будут запущены, а их возвращаемые значения будут отброшены и собранный мусор.

Answer 3

Предупреждение! Если какое-либо Будущее выбрасывает ошибку «Нефатальная», оно будет проглочено. Это серьезная проблема при использовании Future [Unit]: если код никогда не оценивает будущее, ошибки могут исчезнуть из черной дыры. (Это влияет на любое будущее [_], но если вы возвращаете значение, вы обычно делаете что-то с ним, так что обнаружена ошибка.)

scala> import scala.concurrent.ExecutionContext.Implicits.global 
scala.concurrent.Future { throw new IllegalArgumentException("foo") } 

scala> res16: scala.concurrent.Future[Nothing] = scala.concurrent.impl.Promise$DefaultPromise@64dd3f78 

scala> import scala.concurrent.ExecutionContext.Implicits.global 
scala.concurrent.Future { throw new IllegalArgumentException("foo"); 42 } 

scala> res11: scala.concurrent.Future[Int] = scala.concurrent.impl.Promise$DefaultPromise@65c8295b 

Альтернативой, которая выполняет то же самое, но не скрывает ошибка:

scala> val context = scala.concurrent.ExecutionContext.Implicits.global 
context.execute(new Runnable { 
    def run() = throw new IllegalArgumentException("foo") 
}) 
context: scala.concurrent.ExecutionContextExecutor = scala.concurrent.impl.ExecutionContextImpl@1fff4cac 

scala>  |  | java.lang.IllegalArgumentException: foo 
at $line48.$read$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$anon$1.run(<console>:34) 
at $line48.$read$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$iw$$anon$1.run(<console>:33) 
at scala.concurrent.impl.ExecutionContextImpl$$anon$3.exec(ExecutionContextImpl.scala:107) 
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) 
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) 
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) 
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)