Scala Future или другой способ выполнения Java недействительные методы параллельно

Question

У меня есть следующий фрагмент кода:

stringList map copyURLToFile // List[String] 

def copyURLToFile(symbol: String) = { 
    val url = new URL(base.replace("XXX", symbol)) 
    val file = new File(prefix + symbol + ".csv") 
    org.apache.commons.io.FileUtils.copyURLToFile(url, file) 
} 

Как сделать copyURLToFile выполняться параллельно?

Scala Futures нужен тип возврата, но если я сделаю copyURLToFile типа Future [Unit], что и как я вернусь от функции?

Answer 1

Если вам нужен очень простой способ распараллеливать это, то просто переместите список по списку, используя the parallel collections library.

stringList.par.map(copyURLToFile).toList 

Answer 2

Вам нужно что-то вернуть, как вы узнаете, в каких файлах загрузиться?

Изменить код будет:

def copyURLToFile(symbol: String): (String,String) = { 
    val url = new URL(base.replace("XXX", symbol)) 
    val file = new File(prefix + symbol + ".csv") 
    org.apache.commons.io.FileUtils.copyURLToFile(url, file) 
    return (symbol, file) 
} 

А затем полученную коллекция будет содержать символы пути к файлу, в котором они были загружены.