Я смотрел новые параллельные коллекции Scala 2.9 и надеюсь отказаться от многих моих грубых любительских версий подобных вещей. В частности, я хотел бы заменить пул соединений fork, который лежит в основе реализации по умолчанию, чем-то своим...

в scala у меня есть параллельный Iterable элементов, и я хочу перебирать их и каким-то образом агрегировать результаты, но по порядку. я упрощу свой вариант использования и скажу, что мы начинаем с Iterable целых чисел и хотим объединить строковое...

Итак, в качестве домашнего задания я должен поиграть с несколькими механизмами многопоточности, используя простую интеграцию функции, которая должна привести к числу пи. Реализация должна обрабатывать интервал более 500 миллиардов. Моя текущая...

Что я хочу сделать, так это начать с некоторой реализации Map и накапливать в ней данные путем итерации по параллельной коллекции. Ключи могут «перекрываться» между потоками, поскольку ключи генерируются вероятностно (связано с генерацией случайных...

Самый простой способ преобразовать коллекцию Java в эквивалент Scala - это использовать JavaConversions, начиная с версии Scala 2.8. . Эти неявные defs возвращают оболочки для содержащейся коллекции Java. В Scala 2.9 появились параллельные...

Я попытался сделать необязательным выполнение операции map последовательно или параллельно, например, используя следующий код: val runParallel = true val theList = List(1,2,3,4,5) (if(runParallel) theList.par else theList) map println //Doesn't...

Я протестировал параллельные коллекции на Scala и простую коллекцию, вот мой код: def parallelParse() { val adjs = wn.allSynsets(POS.ADJECTIVE).par adjs.foreach(adj => { parse(proc.mkDocument(adj.getGloss)) }) } def...

Я пытаюсь использовать параллельные коллекции Scala для параллельного выполнения некоторых вычислений. Поскольку входных данных много, я использую изменяемые массивы для хранения данных, чтобы избежать проблем с сборщиком мусора. Это первоначальный...

У меня есть код, как показано ниже val g = new Graph(vertices) //Firts part (1 to vertices).par.foreach( i => g + new Vertex(i)) //Second part for (i <- 1 to edges) { val data =...

Я сравниваю 2 фрейма данных в scala/spark, используя вложенный цикл и внешнюю банку. for (nrow <- dfm.rdd.collect) { var mid = nrow.mkString(",").split(",")(0) var mfname = nrow.mkString(",").split(",")(1) var mlname =...