Scalax
|
|
scalax/control/ConcurrentQueue.scala
]
class
ConcurrentQueue[A](val
jq : java.util.concurrent.LinkedBlockingQueue[A])
extends
AnyRefAdditional Constructor Summary | |
def
|
this : ConcurrentQueue[A] |
Method Summary | |
def
|
+= (elem : A) : Unit |
def
|
clear : Unit |
def
|
poll (millis : Long) : scala.Option[A] |
def
|
poll : scala.Option[A] |
def
|
size : Int |
def
|
take : A |
Methods inherited from AnyRef | |
getClass, hashCode, equals, clone, toString, notify, notifyAll, wait, wait, wait, finalize, ==, !=, eq, ne, synchronized |
Methods inherited from Any | |
==, !=, isInstanceOf, asInstanceOf |
Additional Constructor Details |
Method Details |
def
clear : Unit
def
poll : scala.Option[A]
def
poll(millis : Long) : scala.Option[A]
def
size : Int
def
take : A
Scalax
|
|