scalax.control

class ConcurrentQueue

[source: scalax/control/ConcurrentQueue.scala]

class ConcurrentQueue[A](val jq : java.util.concurrent.LinkedBlockingQueue[A])
extends AnyRef
Additional 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
def this : ConcurrentQueue[A]

Method Details
def +=(elem : A) : Unit

def clear : Unit

def poll : scala.Option[A]

def poll(millis : Long) : scala.Option[A]

def size : Int

def take : A


Copyright (c) 2005-8 The Scalax Project. All Rights Reserved.