public interface IndexTaskQueue
Modifier and Type | Method and Description |
---|---|
void |
enqueue(IndexTask task)
Add a new task to this queue.
|
void |
enqueueAll(Collection<IndexTask> tasks)
Add a collection of tasks to this queue.
|
List<IndexTask> |
flushQueue()
Deprecated.
Since 5.6. Use
flushQueue(com.atlassian.fugue.Effect, int) instead. |
int |
flushQueue(com.atlassian.fugue.Effect<IndexTask> action)
Flush the contents of the queue, applying the given action to each
flushed entry.
|
int |
flushQueue(com.atlassian.fugue.Effect<IndexTask> action,
int numberOfEntries)
Flush the contents of the queue, applying the given action to each
flushed entry.
|
List<IndexTask> |
flushQueue(int numberOfEntries)
Deprecated.
Since 5.6. Use
flushQueue(com.atlassian.fugue.Effect, int) instead. |
List<IndexTask> |
getQueuedEntries()
Retrieve a list of all of the queued entries.
|
int |
getSize()
Retrieve the number of elements in the queue.
|
void |
reset()
Remove all queued index tasks from this queue.
|
int getSize()
List<IndexTask> getQueuedEntries()
void enqueue(IndexTask task)
task
- void enqueueAll(Collection<IndexTask> tasks)
tasks
- @Deprecated List<IndexTask> flushQueue(int numberOfEntries)
flushQueue(com.atlassian.fugue.Effect, int)
instead.
Tasks that were added immediately before calling this method are not
returned. See flushQueue()
for an alternative.
numberOfEntries
- the maximum number of entries to return. This should return the n first entries in the queue.@Deprecated List<IndexTask> flushQueue()
flushQueue(com.atlassian.fugue.Effect, int)
instead.
This method waits until tasks that we added immediately before calling
this method are available. See flushQueue(int)
for an
alternative.
int flushQueue(com.atlassian.fugue.Effect<IndexTask> action)
This method waits until tasks that we added immediately before calling
this method are available. See
flushQueue(com.atlassian.fugue.Effect, int)
for an alternative.
action
- action to perform for each entryint flushQueue(com.atlassian.fugue.Effect<IndexTask> action, int numberOfEntries)
Tasks that were added immediately before calling this method are not
returned. See flushQueue(com.atlassian.fugue.Effect)
for an
alternative.
action
- action to perform for each entrynumberOfEntries
- the maximum number of entries to flush. This
should flush the n first entries in the queue.void reset()
Copyright © 2003–2015 Atlassian. All rights reserved.