com.rultor.spi

Class Queue.Memory

java.lang.Object

com.rultor.spi.Queue.Memory

All Implemented Interfaces:

Queue

Enclosing interface:

Queue

@Loggable(value=1)
public static final class Queue.Memory
extends Object
implements Queue

In memory.

Nested Class Summary

Nested classes/interfaces inherited from interface com.rultor.spi.Queue

Queue.Memory

Constructor Summary

Constructors

Constructor and Description
Queue.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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Queue.Memory

public Queue.Memory()

Method Detail

push

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

Description copied from interface: Queue

Push new work into it.

Specified by:

push in interface Queue

Parameters:

work - The work to do

pull

@NotNull
@Loggable(value=1,
          limit=2147483647)
public Coordinates pull(int limit,
                                          @NotNull(message="time unit can\'t be NULL")
                                          TimeUnit unit)
                 throws InterruptedException

Description copied from interface: Queue

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

Specified by:

pull in interface Queue

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