Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 /*
  * JBoss, Home of Professional Open Source
  * Copyright 2012, Red Hat, Inc., and individual contributors
  * by the @authors tag. See the copyright.txt in the distribution for a
  * full listing of individual contributors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
 * http://www.apache.org/licenses/LICENSE-2.0
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.jboss.weld.executor;
Implementation of ExtendedExecutorServices that uses a fixed thread pool. However threads are terminated if no new tasks arrive within the keep-alive time.

Author(s):
Martin Kouba
    private final int threadPoolSize;
    
Keep-alive time in seconds
    private long keepAliveTime;
    private final ThreadPoolExecutor executor;
    public TimingOutFixedThreadPoolExecutorServices(int threadPoolSizelong keepAliveTime) {
        this. = threadPoolSize;
        this. = keepAliveTime;
        this. = new ThreadPoolExecutor(threadPoolSizethreadPoolSize,
                keepAliveTime.,
                new LinkedBlockingQueue<Runnable>(),
                new DaemonThreadFactory(new ThreadGroup("weld-workers"), "weld-worker-"));
        // Terminate threads if no new tasks arrive within the keep-alive time
        this..allowCoreThreadTimeOut(true);
        ..threadsInUse(threadPoolSize);
    }
    public int getPoolSize() {
        return .getPoolSize();
    }
    @Override
    public ExecutorService getTaskExecutor() {
        return ;
    }
    @Override
    protected int getThreadPoolSize() {
        return ;
    }
    public long getKeepAliveTime() {
        return ;
    }
    @Override
    public String toString() {
        return String.format("TimingOutFixedThreadPoolExecutorServices [threadPoolSize=%s, keepAliveTime=%s]",
                );
    }
New to GrepCode? Check out our FAQ X