com.facebook.buck.cli

Class CommandThreadManager

java.lang.Object

com.facebook.buck.cli.CommandThreadManager

All Implemented Interfaces:

AutoCloseable

public class CommandThreadManager
extends Object
implements AutoCloseable

Encapsulates a group of threads which operate a ListeningExecutorService, providing an AutoCloseable interface which waits for and kills the threads on close.

Constructor Summary

Constructors

Constructor and Description
CommandThreadManager(String name, ConcurrencyLimit concurrencyLimit)
CommandThreadManager(String name, ConcurrencyLimit concurrencyLimit, long shutdownTimeout, TimeUnit shutdownTimeoutUnit)
CommandThreadManager(String name, ListeningMultiSemaphore semaphore, ResourceAmounts defaultAmounts, int managedThreadCount)
CommandThreadManager(String name, ListeningMultiSemaphore semaphore, ResourceAmounts defaultAmounts, int managedThreadCount, long shutdownTimeout, TimeUnit shutdownTimeoutUnit)

Method Summary

Modifier and Type	Method and Description
void	close()
ExecutorService	getExecutorService()
com.google.common.util.concurrent.ListeningExecutorService	getListeningExecutorService()
WeightedListeningExecutorService	getWeightedListeningExecutorService()

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandThreadManager

public CommandThreadManager(String name,
                            ListeningMultiSemaphore semaphore,
                            ResourceAmounts defaultAmounts,
                            int managedThreadCount,
                            long shutdownTimeout,
                            TimeUnit shutdownTimeoutUnit)

CommandThreadManager

public CommandThreadManager(String name,
                            ListeningMultiSemaphore semaphore,
                            ResourceAmounts defaultAmounts,
                            int managedThreadCount)

CommandThreadManager

public CommandThreadManager(String name,
                            ConcurrencyLimit concurrencyLimit,
                            long shutdownTimeout,
                            TimeUnit shutdownTimeoutUnit)

CommandThreadManager

public CommandThreadManager(String name,
                            ConcurrencyLimit concurrencyLimit)

Method Detail

getExecutorService

public ExecutorService getExecutorService()

getListeningExecutorService

public com.google.common.util.concurrent.ListeningExecutorService getListeningExecutorService()

getWeightedListeningExecutorService

public WeightedListeningExecutorService getWeightedListeningExecutorService()

close

public void close()
           throws InterruptedException

Specified by:

close in interface AutoCloseable

Throws:

InterruptedException