00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030 package org.openmobileis.embedded.webserver;
00031
00032 import org.openmobileis.common.util.ObjectPool;
00033 import org.openmobileis.common.util.log.*;
00034 import org.openmobileis.common.util.exception.ServerException;
00035 import java.net.*;
00036
00044 public class ServerThreadPool extends ObjectPool {
00045
00046 public ServerThreadPool() throws ClassNotFoundException, IllegalAccessException, InstantiationException {
00047 super("org.openmobileis.embedded.webserver.ServerThread", 5, 5);
00048 }
00049
00050 public synchronized void disposeObject(Object object) {
00051 super.disposeObject(object);
00052 }
00053
00054 public void runServerConnexion(WebServer webserver, Socket socket) {
00055 ServerThread thread = (ServerThread) super.getObject();
00056 if (thread == null) {
00057 LogManager.traceEmergency(LogServices.SYNCHROSERVICE, "Object pool error ServerThread from pool NULL. Create one. System must be repared.");
00058 thread = new ServerThread();
00059 }
00060
00061 try {
00062 thread.init(webserver, socket, this);
00063 } catch (Exception ex) {
00064 LogManager.trace(new ServerException("Error during threadPool init", ex));
00065 LogManager.traceError(0, ex);
00066 }
00067 }
00068
00069 public void freeResources() throws Exception {
00070 for (int i = 0; i < super.arrayPool.size(); i++) {
00071 ServerThread thread = (ServerThread)super.arrayPool.get(i);
00072 thread.notifyStop();
00073 }
00074 }
00075 }
00076