com.facebook.buck.worker

Class WorkerProcessPoolSync

java.lang.Object

com.facebook.buck.worker.WorkerProcessPoolSync

All Implemented Interfaces:

WorkerProcessPool, Closeable, AutoCloseable

@ThreadSafe
public class WorkerProcessPoolSync
extends Object
implements Closeable, WorkerProcessPool

A synchronous pool of WorkerProcess instances.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WorkerProcessPoolSync.BorrowedWorkerProcess Represents a WorkerProcess borrowed from a WorkerProcessPoolSync.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
WorkerProcessPoolSync.BorrowedWorkerProcess	borrowWorkerProcess() If there are available workers, returns one.
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

WorkerProcessPoolSync

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

Method Detail

submitJob

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

Specified by:

submitJob in interface WorkerProcessPool

Throws:

InterruptedException

borrowWorkerProcess

public WorkerProcessPoolSync.BorrowedWorkerProcess borrowWorkerProcess()
                                                                throws InterruptedException

If there are available workers, returns one. Otherwise blocks until one becomes available and returns it. Borrowed worker processes must be relased by calling WorkerProcessPoolSync.BorrowedWorkerProcess.close() after using them.

Throws:

InterruptedException

close

public void close()

Specified by:

close in interface WorkerProcessPool

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getCapacity

public int getCapacity()

Specified by:

getCapacity in interface WorkerProcessPool

getPoolHash

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

Specified by:

getPoolHash in interface WorkerProcessPool