diff options
author | Paul Phillips <paulp@improving.org> | 2011-09-19 13:35:16 +0000 |
---|---|---|
committer | Paul Phillips <paulp@improving.org> | 2011-09-19 13:35:16 +0000 |
commit | 5637b22d21ccc1abe70e16e87c1607cd3acb9b3c (patch) | |
tree | f62eb05f94bf22d0091f65002e7fc98cdc04e1ae /src/library/scala/collection/parallel/mutable/ResizableParArrayCombiner.scala | |
parent | f7e038361ae6b1958985a20e30bfa567d6a51b16 (diff) | |
download | scala-5637b22d21ccc1abe70e16e87c1607cd3acb9b3c.tar.gz scala-5637b22d21ccc1abe70e16e87c1607cd3acb9b3c.tar.bz2 scala-5637b22d21ccc1abe70e16e87c1607cd3acb9b3c.zip |
Deprecation and convention adherence patrol.
Iterators should have def next(), not def next. Clearing
a mutable structure should be done with clear(), not clear.
And etc. No review.
Diffstat (limited to 'src/library/scala/collection/parallel/mutable/ResizableParArrayCombiner.scala')
-rw-r--r-- | src/library/scala/collection/parallel/mutable/ResizableParArrayCombiner.scala | 25 |
1 files changed, 2 insertions, 23 deletions
diff --git a/src/library/scala/collection/parallel/mutable/ResizableParArrayCombiner.scala b/src/library/scala/collection/parallel/mutable/ResizableParArrayCombiner.scala index 2cb0f541d8..eadc93d422 100644 --- a/src/library/scala/collection/parallel/mutable/ResizableParArrayCombiner.scala +++ b/src/library/scala/collection/parallel/mutable/ResizableParArrayCombiner.scala @@ -8,8 +8,6 @@ package scala.collection.parallel.mutable - - import scala.collection.generic.Sizing import scala.collection.mutable.ArraySeq import scala.collection.mutable.ArrayBuffer @@ -18,12 +16,8 @@ import scala.collection.parallel.TaskSupport import scala.collection.parallel.unsupportedop import scala.collection.parallel.Combiner - - /** An array combiner that uses a chain of arraybuffers to store elements. */ -trait ResizableParArrayCombiner[T] -extends LazyCombiner[T, ParArray[T], ExposedArrayBuffer[T]] -{ +trait ResizableParArrayCombiner[T] extends LazyCombiner[T, ParArray[T], ExposedArrayBuffer[T]] { //self: EnvironmentPassingCombiner[T, ParArray[T]] => import collection.parallel.tasksupport._ @@ -40,8 +34,7 @@ extends LazyCombiner[T, ParArray[T], ExposedArrayBuffer[T]] new ParArray(arrayseq) } else { // optimisation if there is only 1 array - val pa = new ParArray(new ExposedArraySeq[T](chain(0).internalArray, size)) - pa + new ParArray(new ExposedArraySeq[T](chain(0).internalArray, size)) } override def toString = "ResizableParArrayCombiner(" + size + "): " //+ chain @@ -88,25 +81,11 @@ extends LazyCombiner[T, ParArray[T], ExposedArrayBuffer[T]] } def shouldSplitFurther = howmany > collection.parallel.thresholdFromSize(size, parallelismLevel) } - } - object ResizableParArrayCombiner { def apply[T](c: ArrayBuffer[ExposedArrayBuffer[T]]): ResizableParArrayCombiner[T] = { new { val chain = c } with ResizableParArrayCombiner[T] // was: with EnvironmentPassingCombiner[T, ParArray[T]] } def apply[T](): ResizableParArrayCombiner[T] = apply(new ArrayBuffer[ExposedArrayBuffer[T]] += new ExposedArrayBuffer[T]) } - - - - - - - - - - - - |