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