com.facebook.buck.worker

Class WorkerProcessPoolAsync

java.lang.Object

com.facebook.buck.worker.WorkerProcessPoolAsync

All Implemented Interfaces:

WorkerProcessPool, Closeable, AutoCloseable

public class WorkerProcessPoolAsync
extends Object
implements WorkerProcessPool

Constructor Summary

Constructors

Constructor and Description
WorkerProcessPoolAsync(int maxRequests, com.google.common.hash.HashCode poolHash, ThrowingSupplier<WorkerProcess,IOException> startWorkerProcess)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getCapacity()
com.google.common.hash.HashCode	getPoolHash()
com.google.common.util.concurrent.ListenableFuture<WorkerJobResult>	submitJob(String expandedJobArgs)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerProcessPoolAsync

public WorkerProcessPoolAsync(int maxRequests,
                              com.google.common.hash.HashCode poolHash,
                              ThrowingSupplier<WorkerProcess,IOException> startWorkerProcess)

Method Detail

getPoolHash

public com.google.common.hash.HashCode getPoolHash()

Specified by:

getPoolHash in interface WorkerProcessPool

getCapacity

public int getCapacity()

Specified by:

getCapacity in interface WorkerProcessPool

submitJob

public com.google.common.util.concurrent.ListenableFuture<WorkerJobResult> submitJob(String expandedJobArgs)
                                                                              throws IOException,
                                                                                     InterruptedException

Specified by:

submitJob in interface WorkerProcessPool

Throws:

IOException

InterruptedException

close

public void close()

Specified by:

close in interface WorkerProcessPool

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable