Class RequestQueue

java.lang.Object

org.mineskin.RequestQueue

public class RequestQueue
extends Object

Constructor Summary

Constructors

Constructor	Description
RequestQueue(ScheduledExecutorService executor, int interval, int concurrency)
RequestQueue(ScheduledExecutorService executor, Supplier<Integer> interval, Supplier<Integer> concurrency)
RequestQueue(IQueueOptions options)

Method Summary

Modifier and Type	Method	Description
int	getConcurrency()
int	getInterval()
long	getNextRequest()
int	getRunning()
void	setNextRequest(long nextRequest)
<T> CompletableFuture<T>	submit(Supplier<CompletableFuture<T>> supplier)
<T> CompletableFuture<T>	submit(Supplier<T> supplier, Executor executor)

Methods inherited from class Object

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

Constructor Details

RequestQueue

public RequestQueue(IQueueOptions options)

RequestQueue

public RequestQueue(ScheduledExecutorService executor,
 int interval,
 int concurrency)

RequestQueue

public RequestQueue(ScheduledExecutorService executor,
 Supplier<Integer> interval,
 Supplier<Integer> concurrency)

Method Details

getInterval

public int getInterval()

getConcurrency

public int getConcurrency()

setNextRequest

public void setNextRequest(long nextRequest)

getNextRequest

public long getNextRequest()

getRunning

public int getRunning()

submit

public <T> CompletableFuture<T> submit(Supplier<CompletableFuture<T>> supplier)

submit

public <T> CompletableFuture<T> submit(Supplier<T> supplier,
 Executor executor)