类 ThreadPoolExecutorFactoryBean

构造器详细资料

• ThreadPoolExecutorFactoryBean

  public ThreadPoolExecutorFactoryBean()

方法详细资料

• setCorePoolSize

  public void setCorePoolSize​(int corePoolSize)

  Set the ThreadPoolExecutor's core pool size. Default is 1.

• setMaxPoolSize

  public void setMaxPoolSize​(int maxPoolSize)

  Set the ThreadPoolExecutor's maximum pool size. Default is Integer.MAX_VALUE.

• setKeepAliveSeconds

  public void setKeepAliveSeconds​(int keepAliveSeconds)

  Set the ThreadPoolExecutor's keep-alive seconds. Default is 60.

• setAllowCoreThreadTimeOut

  public void setAllowCoreThreadTimeOut​(boolean allowCoreThreadTimeOut)

  Specify whether to allow core threads to time out. This enables dynamic growing and shrinking even in combination with a non-zero queue (since the max pool size will only grow once the queue is full).

  Default is "false".

  另请参阅:

  ThreadPoolExecutor.allowCoreThreadTimeOut(boolean)

• setQueueCapacity

  public void setQueueCapacity​(int queueCapacity)

  Set the capacity for the ThreadPoolExecutor's BlockingQueue. Default is Integer.MAX_VALUE.

  Any positive value will lead to a LinkedBlockingQueue instance; any other value will lead to a SynchronousQueue instance.

  另请参阅:

  LinkedBlockingQueue, SynchronousQueue

• setExposeUnconfigurableExecutor

  public void setExposeUnconfigurableExecutor​(boolean exposeUnconfigurableExecutor)

  Specify whether this FactoryBean should expose an unconfigurable decorator for the created executor.

  Default is "false", exposing the raw executor as bean reference. Switch this flag to "true" to strictly prevent clients from modifying the executor's configuration.

  另请参阅:

  Executors.unconfigurableExecutorService(java.util.concurrent.ExecutorService)

• initializeExecutor

  protected ExecutorService initializeExecutor​(ThreadFactory threadFactory,
                                               RejectedExecutionHandler rejectedExecutionHandler)

  从类复制的说明: ExecutorConfigurationSupport
  Create the target ExecutorService instance. Called by afterPropertiesSet.

  指定者:

  initializeExecutor 在类中 ExecutorConfigurationSupport

  参数:

  threadFactory - the ThreadFactory to use

  rejectedExecutionHandler - the RejectedExecutionHandler to use

  返回:

  a new ExecutorService instance

  另请参阅:

  ExecutorConfigurationSupport.afterPropertiesSet()

• createExecutor

  protected ThreadPoolExecutor createExecutor​(int corePoolSize,
                                              int maxPoolSize,
                                              int keepAliveSeconds,
                                              BlockingQueue<Runnable> queue,
                                              ThreadFactory threadFactory,
                                              RejectedExecutionHandler rejectedExecutionHandler)

  Create a new instance of ThreadPoolExecutor or a subclass thereof.

  The default implementation creates a standard ThreadPoolExecutor. Can be overridden to provide custom ThreadPoolExecutor subclasses.

  参数:

  corePoolSize - the specified core pool size

  maxPoolSize - the specified maximum pool size

  keepAliveSeconds - the specified keep-alive time in seconds

  queue - the BlockingQueue to use

  threadFactory - the ThreadFactory to use

  rejectedExecutionHandler - the RejectedExecutionHandler to use

  返回:

  a new ThreadPoolExecutor instance

  另请参阅:

  ExecutorConfigurationSupport.afterPropertiesSet()

• createQueue

  protected BlockingQueue<Runnable> createQueue​(int queueCapacity)

  Create the BlockingQueue to use for the ThreadPoolExecutor.

  A LinkedBlockingQueue instance will be created for a positive capacity value; a SynchronousQueue else.

  参数:

  queueCapacity - the specified queue capacity

  返回:

  the BlockingQueue instance

  另请参阅:

  LinkedBlockingQueue, SynchronousQueue

• getObject

  public ExecutorService getObject()

  从接口复制的说明: FactoryBean
  Return an instance (possibly shared or independent) of the object managed by this factory.

  As with a BeanFactory, this allows support for both the Singleton and Prototype design pattern.

  If this FactoryBean is not fully initialized yet at the time of the call (for example because it is involved in a circular reference), throw a corresponding FactoryBeanNotInitializedException.

  As of Spring 2.0, FactoryBeans are allowed to return null objects. The factory will consider this as normal value to be used; it will not throw a FactoryBeanNotInitializedException in this case anymore. FactoryBean implementations are encouraged to throw FactoryBeanNotInitializedException themselves now, as appropriate.

  指定者:

  getObject 在接口中 FactoryBean<ExecutorService>

  返回:

  an instance of the bean (can be null)

  另请参阅:

  FactoryBeanNotInitializedException

• getObjectType

  public Class<? extends ExecutorService> getObjectType()

  从接口复制的说明: FactoryBean
  Return the type of object that this FactoryBean creates, or null if not known in advance.

  This allows one to check for specific types of beans without instantiating objects, for example on autowiring.

  In the case of implementations that are creating a singleton object, this method should try to avoid singleton creation as far as possible; it should rather estimate the type in advance. For prototypes, returning a meaningful type here is advisable too.

  This method can be called before this FactoryBean has been fully initialized. It must not rely on state created during initialization; of course, it can still use such state if available.

  NOTE: Autowiring will simply ignore FactoryBeans that return null here. Therefore it is highly recommended to implement this method properly, using the current state of the FactoryBean.

  指定者:

  getObjectType 在接口中 FactoryBean<ExecutorService>

  返回:

  the type of object that this FactoryBean creates, or null if not known at the time of the call

  另请参阅:

  ListableBeanFactory.getBeansOfType(java.lang.Class<T>)

• isSingleton

  public boolean isSingleton()

  从接口复制的说明: FactoryBean
  Is the object managed by this factory a singleton? That is, will FactoryBean.getObject() always return the same object (a reference that can be cached)?

  NOTE: If a FactoryBean indicates to hold a singleton object, the object returned from getObject() might get cached by the owning BeanFactory. Hence, do not return true unless the FactoryBean always exposes the same reference.

  The singleton status of the FactoryBean itself will generally be provided by the owning BeanFactory; usually, it has to be defined as singleton there.

  NOTE: This method returning false does not necessarily indicate that returned objects are independent instances. An implementation of the extended SmartFactoryBean interface may explicitly indicate independent instances through its SmartFactoryBean.isPrototype() method. Plain FactoryBean implementations which do not implement this extended interface are simply assumed to always return independent instances if the isSingleton() implementation returns false.

  指定者:

  isSingleton 在接口中 FactoryBean<ExecutorService>

  返回:

  whether the exposed object is a singleton

  另请参阅:

  FactoryBean.getObject(), SmartFactoryBean.isPrototype()