public class ValueQueueService extends java.lang.Object implements ValueConsumer<java.lang.Object>
ForEachJob
.
Values are placed on the queue by setting the value property.
When this service is stopped any iterators in use return false from their hasNext method. This will cause the foreach job to complete.
Constructor and Description |
---|
ValueQueueService() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getName() |
int |
getSize()
Get the current size of the queue.
|
java.lang.Iterable<java.lang.Object> |
getValues()
Get the values.
|
void |
setName(java.lang.String name) |
void |
setValue(java.lang.Object object)
Set a value.
|
void |
start()
Start.
|
void |
stop()
Stop.
|
java.lang.String |
toString() |
public void start()
public void stop()
public java.lang.Iterable<java.lang.Object> getValues()
public void setValue(java.lang.Object object)
setValue
in interface ValueConsumer<java.lang.Object>
object
- public int getSize()
public java.lang.String getName()
public void setName(java.lang.String name)
public java.lang.String toString()
toString
in class java.lang.Object