public class NonQueueingThreadPoolExecutorService extends AbstractExecutorService
| Constructor and Description |
|---|
NonQueueingThreadPoolExecutorService(ThreadFactory threadFactory,
int size) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
void |
execute(Runnable command) |
protected void |
handleException(Runnable task,
Exception e) |
protected void |
handleInterruptedException(InterruptedException e) |
boolean |
isShutdown() |
boolean |
isTerminated() |
protected <T> RunnableFuture<T> |
newTaskFor(Callable<T> callable) |
protected <T> RunnableFuture<T> |
newTaskFor(Runnable runnable,
T value) |
protected void |
onRejectedExecution(Runnable command)
This method is invoked when all threads are busy and cannot accept command for
immediate execution.
|
void |
shutdown() |
List<Runnable> |
shutdownNow() |
public NonQueueingThreadPoolExecutorService(ThreadFactory threadFactory, int size)
public void shutdown()
public List<Runnable> shutdownNow()
public boolean isShutdown()
public boolean isTerminated()
public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException
InterruptedExceptionprotected void handleException(Runnable task, Exception e)
protected void onRejectedExecution(Runnable command)
command - protected void handleInterruptedException(InterruptedException e)
protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value)
newTaskFor in class AbstractExecutorServiceprotected <T> RunnableFuture<T> newTaskFor(Callable<T> callable)
newTaskFor in class AbstractExecutorService