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

=str 20711 IllegalMonitorStateException in Source.queue

Browse source
This commit is contained in:
Alexander Golubev 2016-07-28 08:23:47 -04:00 • committed by Johan Andrén
parent f33f2197b6
commit d0bf45fe68
1 changed files with 2 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala
View file

@ -1309,14 +1309,12 @@ private[akka] trait CallbackWrapper[T] extends AsyncCallback[T] {
callbackState.get() match {
case Initialized(cb) ⇒ cb(arg)
case list @ NotInitialized(l) ⇒ callbackState.compareAndSet(list, NotInitialized(arg :: l))
case Stopped(cb) ⇒
lock.unlock()
cb(arg)
case Stopped(cb) ⇒ cb(arg)
}
}
private[this] def locked(body: ⇒ Unit): Unit = {
lock.lock()
try body finally if (lock.isLocked) lock.unlock()
try body finally lock.unlock()
}
}