public class ManagedQueueExecutorService extends ManagedExecutorService implements org.jboss.threads.BlockingExecutor
Constructor and Description |
---|
ManagedQueueExecutorService(org.jboss.threads.QueueExecutor executor) |
Modifier and Type | Method and Description |
---|---|
void |
executeBlocking(Runnable task) |
void |
executeBlocking(Runnable task,
long timeout,
TimeUnit unit) |
void |
executeNonBlocking(Runnable task) |
int |
getCoreThreads() |
int |
getCurrentThreadCount() |
long |
getKeepAlive() |
int |
getLargestThreadCount() |
int |
getMaxThreads() |
int |
getQueueSize() |
int |
getRejectedCount() |
boolean |
isAllowCoreTimeout() |
boolean |
isBlocking() |
protected ExecutorService |
protectExecutor(ExecutorService executor) |
awaitTermination, execute, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit
public ManagedQueueExecutorService(org.jboss.threads.QueueExecutor executor)
protected ExecutorService protectExecutor(ExecutorService executor)
protectExecutor
in class ManagedExecutorService
public int getCoreThreads()
public boolean isAllowCoreTimeout()
public boolean isBlocking()
public int getMaxThreads()
public long getKeepAlive()
public int getCurrentThreadCount()
public int getLargestThreadCount()
public int getRejectedCount()
public int getQueueSize()
public void executeBlocking(Runnable task) throws RejectedExecutionException, InterruptedException
executeBlocking
in interface org.jboss.threads.BlockingExecutor
RejectedExecutionException
InterruptedException
public void executeBlocking(Runnable task, long timeout, TimeUnit unit) throws RejectedExecutionException, InterruptedException
executeBlocking
in interface org.jboss.threads.BlockingExecutor
RejectedExecutionException
InterruptedException
public void executeNonBlocking(Runnable task) throws RejectedExecutionException
executeNonBlocking
in interface org.jboss.threads.BlockingExecutor
RejectedExecutionException
Copyright © 2023 JBoss by Red Hat. All rights reserved.