parallel-collections

1열

1답변

스칼라 다른 병렬 구조

은 여기, 간단한 수집 대 스칼라에서 병렬 컬렉션을 테스트 내 코드입니다 : def parallelParse() { val adjs = wn.allSynsets(POS.ADJECTIVE).par adjs.foreach(adj => { parse(proc.mkDocument(adj.getGloss)) })

scala collections parallel-processing parallel-collections 2014-07-07

---

2열

1답변

스칼라 병렬 컬렉션 : 작업자 스레드에 스레드 로컬 변수가있는 관용적 방법

아래의 진행률 함수는 내 작업자 함수입니다. 생성/획득하는 데 비용이 많이 드는 클래스에 액세스 할 수 있어야합니다. 이 라이브러리에 대한 스레드 로컬 변수에 대한 표준 기계가 있습니까? 또는 객체 풀 관리자를 직접 작성해야합니까? object Start extends App { def progress { val current = cou

multithreading scala thread-local parallel-collections 2013-12-22

---

8열

1답변

X.par.view와 X.view.par을 사용하여 스칼라 병렬 뷰 생성? 병렬 컬렉션과 인터넷에서 검색의 용지에 따르면

는 , 병렬 컬렉션은 뷰와 함께 작동하도록되어 있지만, 나는 coll.par.view.someChainedIterations 및 coll.view.par.someChainedIterations 것 같다의 차이에 명확하지 않다된다 scala> val coll = 1 to 3 coll: scala.collection.immutable.Range.Inc

scala parallel-processing scala-collections parallel-collections 2013-02-28

---

0열

1답변

가

지금 var distinctElementsDefinitionMap: scala.collection.mutable.ArrayBuffer[HashMap[String, Int]] = new scala.collection.mutable.ArrayBuffer[HashMap[String, Int]](300) with scala.collection.mutable.Syn

multithreading scala synchronization scala-collections parallel-collections 2014-07-11

---

0열

1답변

스칼라 컬렉션에 산술 연산을 매핑하고 결과를 합산합니다.

어제 스터디 그룹과 공유 한 코드는 다음과 같습니다. https://gist.github.com/natemurthy/019e49e6f5f0d1be8719. $ scala -J"-Xmx4G" map 을 4 개 별도의 테스트를 위해 다음과 같은 결과를 얻을 : 컴파일 후, 나는 다음과 같은 힙 PARAMS와 map.scala을 실행 // (1L to 200

scala linear-algebra scala-collections parallel-collections 2014-07-16

---

0열

1답변

ForkJoinPool에서 setMaximumPoolSize를 대체합니다.

스칼라 2.9. * 이후로 setMaximumPoolSize 메서드가 ForkJoinPool에서 사라졌으며 원하는대로 처리되는 것으로 나타났습니다. 스칼라의 병렬 콜렉션에서 병렬 처리를 제한하는 것에 대한 대부분의 논의는 동일한 클래스 (사라졌지 만 나에게는 큰 문제는 아니지만)의 setParallelism 메소드를 중심으로하지만, 필자의 경우 병렬 작업은

scala fork-join parallel-collections 2013-03-11

---

0열

1답변

스칼라에서의 병렬 처리 2.9

~ 10K 개의 요소 배열이 있다고 가정하고 배열의 모든 요소를 ​​처리해야한다고 가정합니다. 나는 K 요소 만 병렬로 처리하는 방식으로 처리하고 싶습니다. 나는 Scala 2.9을 사용합니다. 병렬 수집을 시도했지만 (아래 참조) 이보다 많고 K 요소가 병렬 처리되었습니다. import collection.parallel.ForkJoinTasks.de

scala parallel-processing parallel-collections 2013-06-26

---

6열

1답변

메모리 크기보다 큰 데이터의 병렬 수집 처리

전체 콜렉션을 메모리에로드하지 않고도 스칼라 병렬 수집을 사용하는 간단한 방법이 있습니까? 예를 들어 커다란 컬렉션이 있고 다른 청크보다 메모리에 맞는 작은 청크에서만 특정 작업 (폴드)을 병렬로 수행하고 싶습니다. 모든 덩어리. 나는 액터를 사용할 수 있지만 파 콜렉션을 사용하는 것이 좋을 것이라고 생각합니다. 나는 해결책을 서면으로 작성했습니다,하지만

scala parallel-processing parallel-collections 2013-06-30

---

1열

1답변

ParMap 값 메서드 대체

ParMap (스칼라 2.9에서)에는 .values ​​메서드가없는 것 같습니다. 왜 그런가요? 특히 다음과 같은 처리 과정을 병렬로 유지하려고 할 때 어떻게해야합니까? myParSeq.collect{case i: Interesting => i}.groupBy(_.content).values. ...

scala parallel-collections 2012-12-14

---

3열

1답변

스칼라 병렬 비 순차 반복기

"작업 단위"가 특정 순서없이 수행되어야하는 Iterable입니다. 서로 간섭하지 않고 병렬로 쉽게 실행할 수 있습니다. 불행히도 한 번에 너무 많은 양을 실행하면 사용 가능한 RAM이 초과되므로 주어진 시간에 한 번에 한꺼번에 실행해야합니다. 내가 어디의 지식을 유지하려는 경우 출력 Iterator이 (입력과 같은 순서로 필요는 없다 parMap[A, B

scala parallel-processing iterator parallel-collections 2013-02-06

---