--- projects/cms/source/util/uk/org/iscream/cms/util/Queue.java 2001/01/02 03:24:51 1.2 +++ projects/cms/source/util/uk/org/iscream/cms/util/Queue.java 2001/01/18 19:13:57 1.4 @@ -13,7 +13,7 @@ import uk.ac.ukc.iscream.util.*; * actually contains some elements. * * @author $Author: tdb $ - * @version $Id: Queue.java,v 1.2 2001/01/02 03:24:51 tdb Exp $ + * @version $Id: Queue.java,v 1.4 2001/01/18 19:13:57 tdb Exp $ */ public class Queue { @@ -22,7 +22,7 @@ public class Queue { /** * The current CVS revision of this class */ - public static final String REVISION = "$Revision: 1.2 $"; + public static final String REVISION = "$Revision: 1.4 $"; //---STATIC METHODS--- @@ -116,6 +116,31 @@ public class Queue { } /** + * Returns the size of a given queue. A consumer can use + * this to see how big their queue is at any given time. + * they should use their queue number as the parameter. + * + * @param queue The queue number to query. + * @return the current size of the queue. + */ + public int queueSize(int queue) throws InvalidQueueException { + if (queue >= _lists.size() || _lists.get(queue) == null) { + throw new InvalidQueueException("Requested queue "+queue+" does not exist"); + } + return ((LinkedList) _lists.get(queue)).size(); + } + + /** + * Returns the total numer of elements to have passed + * through this queue (ie. a counter on the add method). + * + * @return the element-ometer + */ + public int elementCount() { + return _count; + } + + /** * This method assigns a queue to a consumer. The idea behind * this is to ensure that only 1 consumer can be associated with * a given queue, otherwise the whole "blocking" thing fails @@ -163,12 +188,12 @@ public class Queue { * * @return the name of this class and its CVS revision */ - /*public String toString() { + public String toString() { return FormatName.getName( _name, getClass().getName(), REVISION); - }*/ + } //---PRIVATE METHODS--- @@ -196,13 +221,7 @@ public class Queue { * can be placed here. This name could also * be changed to null for utility classes. */ - //private String _name = ; - - /** - * This holds a reference to the - * system logger that is being used. - */ - //private Logger _logger = ReferenceManager.getInstance().getLogger(); + private String _name = null; //---STATIC ATTRIBUTES---