raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Adding a todo for AtomicReferenceFieldUpdater in Future.scala

Browse source
This commit is contained in:
Viktor Klang 2011-09-29 17:20:59 +02:00
parent bea02321cd
commit c34b74e13c
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/dispatch/Future.scala
View file

@ -802,7 +802,7 @@ class DefaultPromise[T](val timeout: Timeout)(implicit val dispatcher: MessageDi
def this(timeout: Long, timeunit: TimeUnit)(implicit dispatcher: MessageDispatcher) = this(Timeout(timeout, timeunit))
private val _startTimeInNanos = currentTimeInNanos
private val ref = new AtomicReference[FState[T]](FState())
private val ref = new AtomicReference[FState[T]](FState()) //FIXME create a base-class in Java with an AtomicReferenceFieldUpdater and avoid allocating the AtomicReference for each
@tailrec
private def awaitUnsafe(waitTimeNanos: Long): Boolean = {