Jetty example source code file (ThreadPoolExecutorAdapter.java)

This example Jetty source code file (ThreadPoolExecutorAdapter.java) is included in the DevDaily.com "Java Source Code Warehouse" project. The intent of this project is to help you "Learn Java by Example" ^TM.

Java - Jetty tags/keywords

cannot, cannot, exception, exception, illegalstateexception, interruptedexception, interruptedexception, lifecycle, threading, threadpool, threadpoolexecutor, threadpoolexecutoradapter, threadpoolexecutoradapter, threads

The Jetty ThreadPoolExecutorAdapter.java source code

//========================================================================
//$$Id: ThreadPoolExecutorAdapter.java,v 1.3 2007/11/02 12:39:41 ludovic_orban Exp $$
//
//------------------------------------------------------------------------
//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.mortbay.jetty.j2se6;

import java.util.concurrent.RejectedExecutionException;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import org.mortbay.component.LifeCycle;
import org.mortbay.log.Log;
import org.mortbay.thread.ThreadPool;

/**
 * Jetty {@link ThreadPool} that bridges requests to a {@link ThreadPoolExecutor}.
 * @author lorban
 */
public class ThreadPoolExecutorAdapter implements ThreadPool, LifeCycle
{
	
	private ThreadPoolExecutor executor;
	
	public ThreadPoolExecutorAdapter(ThreadPoolExecutor executor)
	{
		this.executor = executor;
	}

	public boolean dispatch(Runnable job)
	{
		try
        {       
			executor.execute(job);
            return true;
        }
        catch(RejectedExecutionException e)
        {
            Log.warn(e);
            return false;
        }
	}

	public int getIdleThreads()
	{
		return executor.getPoolSize()-executor.getActiveCount();
	}

	public int getThreads()
	{
		return executor.getPoolSize();
	}

	public boolean isLowOnThreads()
	{
		return executor.getActiveCount()>=executor.getMaximumPoolSize();
	}

	public void join() throws InterruptedException
	{
		executor.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
	}

	
	
	public boolean isFailed()
	{
		return false;
	}

	public boolean isRunning()
	{
		return !executor.isTerminated() && !executor.isTerminating();
	}

	public boolean isStarted()
	{
		return !executor.isTerminated() && !executor.isTerminating();
	}

	public boolean isStarting()
	{
		return false;
	}

	public boolean isStopped()
	{
		return executor.isTerminated();
	}

	public boolean isStopping()
	{
		return executor.isTerminating();
	}

	public void start() throws Exception
	{
		if (executor.isTerminated() || executor.isTerminating() || executor.isShutdown())
            throw new IllegalStateException("Cannot restart");
	}

	public void stop() throws Exception
	{
		executor.shutdown();
        if (!executor.awaitTermination(60,TimeUnit.SECONDS))
        	executor.shutdownNow();
	}

}