diff options
author | Viktor Klang <viktor.klang@gmail.com> | 2012-07-13 18:11:53 +0200 |
---|---|---|
committer | Viktor Klang <viktor.klang@gmail.com> | 2012-07-13 18:11:53 +0200 |
commit | 47652e692a5bdcbc18de2881e86267d37757751d (patch) | |
tree | e8c7cf6922c4ab05517e6a432309235ebfcdec07 /src | |
parent | 1b6468cd6178249919885847ae55bf3f33372a2a (diff) | |
download | scala-47652e692a5bdcbc18de2881e86267d37757751d.tar.gz scala-47652e692a5bdcbc18de2881e86267d37757751d.tar.bz2 scala-47652e692a5bdcbc18de2881e86267d37757751d.zip |
Fixing oversight in propagating the runnable into the newly created thread.
Diffstat (limited to 'src')
-rw-r--r-- | src/library/scala/concurrent/impl/ExecutionContextImpl.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/library/scala/concurrent/impl/ExecutionContextImpl.scala b/src/library/scala/concurrent/impl/ExecutionContextImpl.scala index ccac565eea..6c4145e2d5 100644 --- a/src/library/scala/concurrent/impl/ExecutionContextImpl.scala +++ b/src/library/scala/concurrent/impl/ExecutionContextImpl.scala @@ -34,7 +34,7 @@ private[scala] class ExecutionContextImpl private[impl] (es: Executor, reporter: thread } - def newThread(runnable: Runnable): Thread = wire(new Thread()) + def newThread(runnable: Runnable): Thread = wire(new Thread(runnable)) def newThread(fjp: ForkJoinPool): ForkJoinWorkerThread = wire(new ForkJoinWorkerThread(fjp) with BlockContext { override def internalBlockingCall[T](awaitable: Awaitable[T], atMost: Duration): T = { |