public class ManagedJBossThreadPoolExecutorService extends ManagedExecutorService implements org.jboss.threads.BlockingExecutor
Constructor and Description |
---|
ManagedJBossThreadPoolExecutorService(org.jboss.threads.JBossThreadPoolExecutor executor) |
Modifier and Type | Method and Description |
---|---|
void |
executeBlocking(Runnable task) |
void |
executeBlocking(Runnable task,
long timeout,
TimeUnit unit) |
void |
executeNonBlocking(Runnable task) |
int |
getActiveCount() |
long |
getCompletedTaskCount() |
int |
getCoreThreads() |
int |
getCurrentThreadCount() |
long |
getKeepAlive() |
int |
getLargestPoolSize() |
int |
getLargestThreadCount() |
int |
getMaxThreads() |
int |
getQueueSize() |
int |
getRejectedCount() |
long |
getTaskCount() |
boolean |
isAllowCoreTimeout() |
boolean |
isBlocking() |
protected ExecutorService |
protectExecutor(ExecutorService executor) |
awaitTermination, execute, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit
public ManagedJBossThreadPoolExecutorService(org.jboss.threads.JBossThreadPoolExecutor 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 getRejectedCount()
public long getTaskCount()
public int getLargestThreadCount()
public int getLargestPoolSize()
public int getCurrentThreadCount()
public long getCompletedTaskCount()
public int getActiveCount()
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.