com.rultor.spi

Interface Queue

All Known Implementing Classes:

Queue.Memory

@Immutable
public interface Queue

Queue.

Since:

1.0

Version:

$Id$

Author:

Yegor Bugayenko (yegor@tpc2.com)

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	Queue.Memory In memory.

Method Summary

Methods

Modifier and Type	Method and Description
Coordinates	pull(int limit, TimeUnit unit) Pull the next available work (waits until it is available).
void	push(Coordinates work) Push new work into it.

Method Detail

push

void push(@NotNull(message="work can\'t be NULL")
        Coordinates work)

Push new work into it.

Parameters:

work - The work to do

pull

@NotNull(message="work is never NULL")
Coordinates pull(int limit,
                              @NotNull(message="time unit can\'t be NULL")
                              TimeUnit unit)
                 throws InterruptedException

Pull the next available work (waits until it is available).

Parameters:

limit - How many time rules to wait for, maximum

unit - Time unit

Returns:

The work available or Coordinates.None if nothing is available now

Throws:

InterruptedException - If interrupted while waiting