com.facebook.buck.util.concurrent

Class JobLimiter

java.lang.Object

com.facebook.buck.util.concurrent.JobLimiter

public class JobLimiter
extends Object

JobLimiter is a simple mechanism for queuing asynchronous work such that only a certain number of items are active at a time.

Constructor Summary

Constructors

Constructor and Description
JobLimiter(int limit)

Method Summary

Modifier and Type	Method and Description
<V> com.google.common.util.concurrent.ListenableFuture<V>	schedule(com.google.common.util.concurrent.ListeningExecutorService service, ThrowingSupplier<com.google.common.util.concurrent.ListenableFuture<V>,Exception> callable) Adds a new task to the queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

JobLimiter

public JobLimiter(int limit)

Method Detail

schedule

public <V> com.google.common.util.concurrent.ListenableFuture<V> schedule(com.google.common.util.concurrent.ListeningExecutorService service,
                                                                          ThrowingSupplier<com.google.common.util.concurrent.ListenableFuture<V>,Exception> callable)

Adds a new task to the queue. JobLimiter uses the provided service only for invoking the callable itself.