public class BoundedQueueThreadPoolService extends Object implements org.jboss.msc.service.Service<ManagedQueueExecutorService>
Constructor and Description |
---|
BoundedQueueThreadPoolService(int coreThreads,
int maxThreads,
int queueLength,
boolean blocking,
TimeSpec keepAlive,
boolean allowCoreTimeout) |
Modifier and Type | Method and Description |
---|---|
int |
getCurrentThreadCount() |
org.jboss.msc.inject.Injector<Executor> |
getHandoffExecutorInjector() |
int |
getLargestThreadCount() |
int |
getQueueSize() |
int |
getRejectedCount() |
org.jboss.msc.inject.Injector<ThreadFactory> |
getThreadFactoryInjector() |
ManagedQueueExecutorService |
getValue() |
void |
setAllowCoreTimeout(boolean allowCoreTimeout) |
void |
setCoreThreads(int coreThreads) |
void |
setKeepAlive(TimeSpec keepAlive) |
void |
setMaxThreads(int maxThreads) |
void |
start(org.jboss.msc.service.StartContext context) |
void |
stop(org.jboss.msc.service.StopContext context) |
public BoundedQueueThreadPoolService(int coreThreads, int maxThreads, int queueLength, boolean blocking, TimeSpec keepAlive, boolean allowCoreTimeout)
public void start(org.jboss.msc.service.StartContext context) throws org.jboss.msc.service.StartException
start
in interface org.jboss.msc.service.Service<ManagedQueueExecutorService>
org.jboss.msc.service.StartException
public void stop(org.jboss.msc.service.StopContext context)
stop
in interface org.jboss.msc.service.Service<ManagedQueueExecutorService>
public ManagedQueueExecutorService getValue() throws IllegalStateException
getValue
in interface org.jboss.msc.value.Value<ManagedQueueExecutorService>
IllegalStateException
public org.jboss.msc.inject.Injector<ThreadFactory> getThreadFactoryInjector()
public org.jboss.msc.inject.Injector<Executor> getHandoffExecutorInjector()
public void setCoreThreads(int coreThreads)
public void setMaxThreads(int maxThreads)
public void setKeepAlive(TimeSpec keepAlive)
public void setAllowCoreTimeout(boolean allowCoreTimeout)
public int getCurrentThreadCount()
public int getLargestThreadCount()
public int getRejectedCount()
public int getQueueSize()
Copyright © 2023 JBoss by Red Hat. All rights reserved.