summaryrefslogtreecommitdiff
path: root/src/library/scala/collection/parallel/Tasks.scala
diff options
context:
space:
mode:
authorAleksandar Pokopec <aleksandar.prokopec@epfl.ch>2011-03-22 18:23:28 +0000
committerAleksandar Pokopec <aleksandar.prokopec@epfl.ch>2011-03-22 18:23:28 +0000
commit142405e1dd623e965e7ce5a3bc4fa019bc3262fa (patch)
treecf3fda893881d2c43b02d9fc3fa119295dd78eb8 /src/library/scala/collection/parallel/Tasks.scala
parente579152f7329a314607d33c7e3761b769b93518d (diff)
downloadscala-142405e1dd623e965e7ce5a3bc4fa019bc3262fa.tar.gz
scala-142405e1dd623e965e7ce5a3bc4fa019bc3262fa.tar.bz2
scala-142405e1dd623e965e7ce5a3bc4fa019bc3262fa.zip
Adding some tests for #3651.
No review.
Diffstat (limited to 'src/library/scala/collection/parallel/Tasks.scala')
-rw-r--r--src/library/scala/collection/parallel/Tasks.scala5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/library/scala/collection/parallel/Tasks.scala b/src/library/scala/collection/parallel/Tasks.scala
index f855dede19..0b220a020f 100644
--- a/src/library/scala/collection/parallel/Tasks.scala
+++ b/src/library/scala/collection/parallel/Tasks.scala
@@ -244,7 +244,10 @@ trait ThreadPoolTasks extends Tasks {
// utb: future.get()
executor.synchronized {
val coresize = executor.getCorePoolSize
- if (coresize < totaltasks) executor.setCorePoolSize(coresize + 1)
+ if (coresize < totaltasks) {
+ executor.setCorePoolSize(coresize + 1)
+ //assert(executor.getCorePoolSize == (coresize + 1))
+ }
}
if (!completed) this.wait
}