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

Refining names

Browse source
This commit is contained in:
Viktor Klang 2010-08-25 16:03:55 +02:00
parent 957e184af6
commit c288afa8b6
1 changed files with 7 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

17
akka-core/src/main/scala/dispatch/Queues.scala
View file

@ -11,17 +11,14 @@ import se.scalablesolutions.akka.util.Logger
class BoundedTransferQueue[E <: AnyRef](
val capacity: Int,
val defaultTimeout: Long,
val defaultTimeUnit: TimeUnit)
val pushTimeout: Long,
val pushTimeUnit: TimeUnit)
extends LinkedTransferQueue[E] {
protected val guard = new Semaphore(capacity)
protected def enq(
f: => Boolean,
timeout: Long = defaultTimeout,
unit: TimeUnit = defaultTimeUnit): Boolean = {
if (guard.tryAcquire(timeout,unit)) {
protected def enq(f: => Boolean): Boolean = {
if (guard.tryAcquire(pushTimeout,pushTimeUnit)) {
val result = try {
f
} catch {
@ -54,7 +51,7 @@ class BoundedTransferQueue[E <: AnyRef](
enq(super.offer(e))
override def offer(e: E, timeout: Long, unit: TimeUnit): Boolean =
enq(super.offer(e,timeout,unit), timeout, unit)
enq(super.offer(e,timeout,unit))
override def add(e: E): Boolean =
enq(super.add(e))
@ -66,7 +63,7 @@ class BoundedTransferQueue[E <: AnyRef](
enq(super.tryTransfer(e))
override def tryTransfer(e: E, timeout: Long, unit: TimeUnit): Boolean =
enq(super.tryTransfer(e,timeout,unit),timeout,unit)
enq(super.tryTransfer(e,timeout,unit))
override def transfer(e: E): Unit =
enq({ super.transfer(e); true })
@ -78,7 +75,7 @@ class BoundedTransferQueue[E <: AnyRef](
def next = it.next
def remove {
it.remove
guard.release
guard.release //Assume remove worked if no exception was thrown
}
}
}