XmlRpcWorkerFactory.java

Go to the documentation of this file.

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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.apache.xmlrpc.common;

import java.util.ArrayList;
import java.util.List;


public abstract class XmlRpcWorkerFactory {
        private final XmlRpcWorker singleton = newWorker();
        private final XmlRpcController controller;
        private final List pool = new ArrayList();
        private int numThreads;

        public XmlRpcWorkerFactory(XmlRpcController pController) {
                controller = pController;
        }

        protected abstract XmlRpcWorker newWorker();

        public XmlRpcController getController() {
                return controller;
        }

        public synchronized XmlRpcWorker getWorker() throws XmlRpcLoadException {
                int max = controller.getMaxThreads();
                if (max > 0  &&  numThreads == max) {
                        throw new XmlRpcLoadException("Maximum number of concurrent requests exceeded: " + max);
                }
                if (max == 0) {
                        return singleton;
                }
        ++numThreads;
                if (pool.size() == 0) {
                        return newWorker();
                } else {
                        return (XmlRpcWorker) pool.remove(pool.size() - 1);
                }
        }

        public synchronized void releaseWorker(XmlRpcWorker pWorker) {
                --numThreads;
                int max = controller.getMaxThreads();
                if (pWorker == singleton) {
                        // Do nothing, it's the singleton
                } else {
                        if (pool.size() < max) {
                                pool.add(pWorker);
                        }
                }
        }

        public synchronized int getCurrentRequests() {
                return numThreads;
        }
}