Class QueueTemplate.Queue
java.lang.Object
sunlabs.brazil.template.QueueTemplate.Queue
- Enclosing class:
QueueTemplate
Create an object queue. "Getters" wait 'till something
appears in the queue.
- Version:
- @(#)QueueTemplate.java 1.5 1.5
- Author:
- Stephen Uhler
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
clear()
Clear the queue.long
count()
Return the total number of items Q'd.get
(int timeout) Return the next item on the queue, waiting for up to "timeout" seconds or for an interrupt.long
Return creation time (ms since epoch).long
Get the expiration period of the Queue (in ms).boolean
isClosed()
Get the closed state.void
kick()
Send a notify: for debugginglong
lastIn()
Return the last time a Q insertion was attempted.long
lastOut()
Return the last time a Q removal was attempted.boolean
Put an item on the queue if it's open and not full.boolean
Put an item on the queue if it's not full.boolean
setClosed
(boolean closed) Set the closed state.void
setExpires
(long expires) Set the expiration period of the Queue (in ms).int
size()
How many items are queue'd.toString()
-
Field Details
-
max
public static int max
-
-
Constructor Details
-
Queue
public Queue()Create a new Q of a maximum possible size
-
-
Method Details
-
get
Return the next item on the queue, waiting for up to "timeout" seconds or for an interrupt.- Returns:
- the top of the Q, or null.
-
put
Put an item on the queue if it's open and not full. -
put
Put an item on the queue if it's not full. If "force" is true, override the "closed" flag. -
size
public int size()How many items are queue'd. -
kick
public void kick()Send a notify: for debugging -
lastIn
public long lastIn()Return the last time a Q insertion was attempted.- Returns:
- -1 if no attempts were made.
-
lastOut
public long lastOut()Return the last time a Q removal was attempted.- Returns:
- -1 if no attempts were made.
-
count
public long count()Return the total number of items Q'd.- Returns:
- The # of Q'd items.
-
getExpires
public long getExpires()Get the expiration period of the Queue (in ms). The notion of when a queue expires is application dependent. Applications can look at count() lastIn(), lastOut(). and created() to determine when the Q is expired for them. -
setExpires
public void setExpires(long expires) Set the expiration period of the Queue (in ms). -
getCreated
public long getCreated()Return creation time (ms since epoch). -
clear
public void clear()Clear the queue. -
setClosed
public boolean setClosed(boolean closed) Set the closed state. -
isClosed
public boolean isClosed()Get the closed state. -
toString
-