Package EDU.oswego.cs.dl.util.concurrent

Examples of EDU.oswego.cs.dl.util.concurrent.PooledExecutor$AbortWhenBlocked


     * one.
     *
     * @param maxSize Maximum size of the work executor pool.
     */
    public WorkExecutorPoolImpl(int maxSize) {
        pooledExecutor = new PooledExecutor(new LinkedQueue(), maxSize);
        pooledExecutor.setMinimumPoolSize(maxSize);
        pooledExecutor.waitWhenBlocked();
    }
View Full Code Here


     * @param maxSize Maximum size of the work executor pool.
     */
    public WorkExecutorPoolImpl(
            Channel channel,
            int maxSize) {
        pooledExecutor = new PooledExecutor(channel, maxSize);
        pooledExecutor.setMinimumPoolSize(maxSize);
        pooledExecutor.waitWhenBlocked();
    }
View Full Code Here

     * one.
     *
     * @param maxSize Maximum size of the work executor pool.
     */
    public WorkExecutorPoolImpl(int maxSize) {
        pooledExecutor = new PooledExecutor(new LinkedQueue(), maxSize);
        pooledExecutor.setMinimumPoolSize(maxSize);
        pooledExecutor.waitWhenBlocked();
    }
View Full Code Here

     * @param maxSize Maximum size of the work executor pool.
     */
    public WorkExecutorPoolImpl(
            Channel channel,
            int maxSize) {
        pooledExecutor = new PooledExecutor(channel, maxSize);
        pooledExecutor.setMinimumPoolSize(maxSize);
        pooledExecutor.waitWhenBlocked();
    }
View Full Code Here

    * @param maxPoolSize DOCUMENT_ME
    */
   public WorkManagerImpl( int maxPoolSize )
   {
      LOG.debug(MSG.getMessage( Keys.CREATE_WRK_MGR_POOL_SZE, Integer.toString(maxPoolSize)));
      this.pool = new PooledExecutor( maxPoolSize );
   }
View Full Code Here

            c = new LinkedQueue();
        } else {
            c = new BoundedBuffer(queueSize);
        }

        pool = new PooledExecutor(c, maxPoolSize);
        pool.setMinimumPoolSize(minPoolSize);
        pool.setKeepAliveTime(1000 * 60 * threadKeepAliveTime);

        workerMap = new HashMap();

View Full Code Here

            c = new LinkedQueue();
        } else {
            c = new BoundedBuffer(queueSize);
        }

        pool = new PooledExecutor(c, maxPoolSize);
        pool.setMinimumPoolSize(minPoolSize);
        pool.setKeepAliveTime(1000 * 60 * threadKeepAliveTime);

        workerMap = new HashMap();
        workflowQueue = new Vector();
View Full Code Here

    /**
     * Creates a new DynamicPooledExecutor.
     */
    public DynamicPooledExecutor() {
        executor = new PooledExecutor();
        executor.setKeepAliveTime(500);
        executor.waitWhenBlocked();
        adjustPoolSize();
    }
View Full Code Here

      c = new LinkedQueue();
    } else {
      c = new BoundedBuffer(queueSize);
    }

    pool = new PooledExecutor(c, maxPoolSize);
    pool.setMinimumPoolSize(minPoolSize);
    pool.setKeepAliveTime(1000 * 60 * threadKeepAliveTime);

    workerMap = new HashMap();

View Full Code Here

    * @param maxPoolSize DOCUMENT_ME
    */
   public WorkManagerImpl( int maxPoolSize )
   {
      LOG.debug(MSG.getMessage( Keys.CREATE_WRK_MGR_POOL_SZE, Integer.toString(maxPoolSize)));
      this.pool = new PooledExecutor( maxPoolSize );
   }
View Full Code Here

TOP

Related Classes of EDU.oswego.cs.dl.util.concurrent.PooledExecutor$AbortWhenBlocked

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.