diff options
| author | Aleksandar Prokopec <axel22@gmail.com> | 2012-02-15 16:04:04 +0100 |
|---|---|---|
| committer | Aleksandar Prokopec <axel22@gmail.com> | 2012-02-15 16:04:04 +0100 |
| commit | 7c689e365f333d05fc94c890d9579f3721057ea8 (patch) | |
| tree | 4eae89cf9bd79a39c45b7c3dcc52125b81efc157 | |
| parent | fe6c9e3f1693f2e6db5ae69517893894bbac6afb (diff) | |
| download | scala-7c689e365f333d05fc94c890d9579f3721057ea8.tar.gz scala-7c689e365f333d05fc94c890d9579f3721057ea8.tar.bz2 scala-7c689e365f333d05fc94c890d9579f3721057ea8.zip | |
Implement `remaining` method in ParCtrie splitter.
| -rw-r--r-- | src/library/scala/collection/parallel/mutable/ParCtrie.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/library/scala/collection/parallel/mutable/ParCtrie.scala b/src/library/scala/collection/parallel/mutable/ParCtrie.scala index 1e11b85da5..8cf8b6167e 100644 --- a/src/library/scala/collection/parallel/mutable/ParCtrie.scala +++ b/src/library/scala/collection/parallel/mutable/ParCtrie.scala @@ -124,8 +124,7 @@ extends CtrieIterator[K, V](lev, ct, mustInit) with IterableSplitter[(K, V)] { // only evaluated if `remaining` is invoked (which is not used by most tasks) - //lazy val totalsize = ct.iterator.size /* TODO improve to lazily compute sizes */ - def totalsize: Int = throw new UnsupportedOperationException + lazy val totalsize = ct.par.size var iterated = 0 protected override def newIterator(_lev: Int, _ct: Ctrie[K, V], _mustInit: Boolean) = new ParCtrieSplitter[K, V](_lev, _ct, _mustInit) |