ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/util/uk/org/iscream/cms/util/Queue.java
(Generate patch)

Comparing projects/cms/source/util/uk/org/iscream/cms/util/Queue.java (file contents):
Revision 1.3 by tdb, Thu Jan 18 01:55:36 2001 UTC vs.
Revision 1.6 by tdb, Tue Jan 23 18:22:28 2001 UTC

# Line 88 | Line 88 | public class Queue {
88          }
89          return o;
90      }
91 <      
91 >    
92      /**
93 +     * This method releases a get() method that's currently
94 +     * waiting on an empty queue. This was designed for
95 +     * shutdown() type methods that may have problems closing
96 +     * if the thread of control is waiting on a queue.
97 +     *
98 +     * @param queue the queue to release
99 +     */
100 +    public void releaseQueue(int queue) {
101 +        synchronized(((LinkedList) _lists.get(queue))) {
102 +                ((LinkedList) _lists.get(queue)).notifyAll();
103 +        }
104 +    }
105 +    
106 +    /**
107       * This method returns a textual status of the queues. It
108       * is merely for observation, and would most likely be used
109       * by a larger "monitoring" component. Information returned
# Line 113 | Line 127 | public class Queue {
127          }
128          status += "A total of "+_count+" elements have been added to the queues";
129          return status;
130 +    }
131 +    
132 +    /**
133 +     * Returns the size of a given queue. A consumer can use
134 +     * this to see how big their queue is at any given time.
135 +     * they should use their queue number as the parameter.
136 +     *
137 +     * @param queue The queue number to query.
138 +     * @return the current size of the queue.
139 +     */
140 +    public int queueSize(int queue) throws InvalidQueueException {
141 +        if (queue >= _lists.size() || _lists.get(queue) == null) {
142 +            throw new InvalidQueueException("Requested queue "+queue+" does not exist");
143 +        }
144 +        return ((LinkedList) _lists.get(queue)).size();
145 +    }
146 +    
147 +    /**
148 +     * Returns the total numer of elements to have passed
149 +     * through this queue (ie. a counter on the add method).
150 +     *
151 +     * @return the element-ometer
152 +     */
153 +    public int elementCount() {
154 +        return _count;
155      }
156      
157      /**

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines