001: /*
002: License $Id: HandlerPool.java,v 1.4 2003/09/13 04:59:56 hendriks73 Exp $
003:
004: Copyright (c) 2001-2005 tagtraum industries.
005:
006: LGPL
007: ====
008:
009: jo! is free software; you can redistribute it and/or
010: modify it under the terms of the GNU Lesser General Public
011: License as published by the Free Software Foundation; either
012: version 2.1 of the License, or (at your option) any later version.
013:
014: jo! is distributed in the hope that it will be useful,
015: but WITHOUT ANY WARRANTY; without even the implied warranty of
016: MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
017: Lesser General Public License for more details.
018:
019: You should have received a copy of the GNU Lesser General Public
020: License along with this library; if not, write to the Free Software
021: Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
022:
023: For LGPL see <http://www.fsf.org/copyleft/lesser.txt>
024:
025:
026: Sun license
027: ===========
028:
029: This release contains software by Sun Microsystems. Therefore
030: the following conditions have to be met, too. They apply to the
031: files
032:
033: - lib/mail.jar
034: - lib/activation.jar
035: - lib/jsse.jar
036: - lib/jcert.jar
037: - lib/jaxp.jar
038: - lib/crimson.jar
039: - lib/servlet.jar
040: - lib/jnet.jar
041: - lib/jaas.jar
042: - lib/jaasmod.jar
043:
044: contained in this release.
045:
046: a. Licensee may not modify the Java Platform
047: Interface (JPI, identified as classes contained within the javax
048: package or any subpackages of the javax package), by creating additional
049: classes within the JPI or otherwise causing the addition to or modification
050: of the classes in the JPI. In the event that Licensee creates any
051: Java-related API and distribute such API to others for applet or
052: application development, you must promptly publish broadly, an accurate
053: specification for such API for free use by all developers of Java-based
054: software.
055:
056: b. Software is confidential copyrighted information of Sun and
057: title to all copies is retained by Sun and/or its licensors. Licensee
058: shall not modify, decompile, disassemble, decrypt, extract, or otherwise
059: reverse engineer Software. Software may not be leased, assigned, or
060: sublicensed, in whole or in part. Software is not designed or intended
061: for use in on-line control of aircraft, air traffic, aircraft navigation
062: or aircraft communications; or in the design, construction, operation or
063: maintenance of any nuclear facility. Licensee warrants that it will not
064: use or redistribute the Software for such purposes.
065:
066: c. Software is provided "AS IS," without a warranty
067: of any kind. ALL EXPRESS OR IMPLIED REPRESENTATIONS AND WARRANTIES,
068: INCLUDING ANY IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A
069: PARTICULAR PURPOSE OR NON-INFRINGEMENT, ARE HEREBY EXCLUDED.
070:
071: d. This License is effective until terminated. Licensee may
072: terminate this License at any time by destroying all copies of Software.
073: This License will terminate immediately without notice from Sun if Licensee
074: fails to comply with any provision of this License. Upon such termination,
075: Licensee must destroy all copies of Software.
076:
077: e. Software, including technical data, is subject to U.S.
078: export control laws, including the U.S. Export Administration Act and its
079: associated regulations, and may be subject to export or import regulations
080: in other countries. Licensee agrees to comply strictly with all such
081: regulations and acknowledges that it has the responsibility to obtain
082: licenses to export, re-export, or import Software. Software may not be
083: downloaded, or otherwise exported or re-exported (i) into, or to a national
084: or resident of, Cuba, Iraq, Iran, North Korea, Libya, Sudan, Syria or any
085: country to which the U.S. has embargoed goods; or (ii) to anyone on the
086: U.S. Treasury Department's list of Specially Designated Nations or the U.S.
087: Commerce Department's Table of Denial Orders.
088:
089:
090: Feedback
091: ========
092:
093: We encourage your feedback and suggestions and want to use your feedback to
094: improve the Software. Send all such feedback to:
095: <feedback@tagtraum.com>
096:
097: For more information on tagtraum industries and jo!
098: please see <http://www.tagtraum.com/>.
099:
100:
101: */
102: package com.tagtraum.framework.server;
103:
104: import com.tagtraum.framework.util.I_Pool;
105: import com.tagtraum.framework.util.Pool;
106:
107: import java.util.ArrayList;
108: import java.util.Iterator;
109:
110: /**
111: * With the <code>HandlerPool</code> we make sure
112: * that all {@link I_Handler}s are destroyed when applicable.
113: * It is also possible to trim the pool if necessary.
114: *
115: * @author <a href="mailto:hs@tagtraum.com">Hendrik Schreiber</a>
116: * @version 1.1beta1 $Id: HandlerPool.java,v 1.4 2003/09/13 04:59:56 hendriks73 Exp $
117: */
118: public class HandlerPool extends Pool implements I_Pool {
119:
120: /**
121: * Source-Version
122: */
123: public static String vcid = "$Id: HandlerPool.java,v 1.4 2003/09/13 04:59:56 hendriks73 Exp $";
124:
125: /**
126: * All Handlers.
127: */
128: protected ArrayList myHandlers = new ArrayList();
129: protected int peakRegisteredHandlers = 0;
130:
131: /**
132: * Registers a {@link I_Handler} with this pool.<p>
133: *
134: * @param aHandler Handler to register
135: * @see Service#getHandler()
136: */
137: public synchronized void registerHandler(I_Handler aHandler) {
138: myHandlers.add(aHandler);
139:
140: if (myHandlers.size() > peakRegisteredHandlers) {
141: peakRegisteredHandlers = myHandlers.size();
142: }
143: }
144:
145: /**
146: * Removes a {@link I_Handler} from a pool an calls
147: * it {@link I_Handler#destroy()} method.
148: *
149: * @param aHandler handler to de-register
150: */
151: public synchronized void unregisterHandler(I_Handler aHandler) {
152: myHandlers.remove(aHandler);
153: myObjects.remove(aHandler);
154: aHandler.destroy();
155: }
156:
157: /**
158: * Clears the pool.
159: */
160: public synchronized void clear() {
161: Iterator i = myHandlers.iterator();
162:
163: while (i.hasNext()) {
164: ((I_Handler) i.next()).destroy();
165: }
166:
167: myHandlers.clear();
168: myObjects.clear();
169:
170: peakRegisteredHandlers = 0;
171: }
172:
173: /**
174: * Trims the pool to its capacity.
175: */
176: protected void trim() {
177: trim(getCapacity());
178: }
179:
180: /**
181: * Trims the pool to a specified size.
182: *
183: * @param size final size
184: */
185: public synchronized void trim(int size) {
186: if (size < 0) {
187: throw new IllegalArgumentException(
188: "Trim size can't be less than zero: " + size);
189: }
190:
191: while (myObjects.size() > size) {
192: I_Handler aHandler = (I_Handler) myObjects.removeFirst();
193:
194: myHandlers.remove(aHandler);
195: aHandler.destroy();
196:
197: aHandler = null;
198: }
199: }
200:
201: /**
202: * Returns the number of registered {@link I_Handler}s.
203: *
204: * @return number of registered {@link I_Handler}s
205: */
206: public int countRegisteredHandlers() {
207: return myHandlers.size();
208: }
209:
210: /**
211: * Returns the maximum number of ever registered {@link I_Handler}s.
212: *
213: * @return max number of registered {@link I_Handler}s
214: */
215: public int countPeakRegisteredHandlers() {
216: return peakRegisteredHandlers;
217: }
218:
219: /**
220: * Adds an object to this pool. This is a slighly faster implementation
221: * than in {@link Pool}. Note that it does neither checks the capacity
222: * nor whether the Object is already in the pool.
223: *
224: * @param aObject object to add
225: * @see com.tagtraum.framework.recycler.Recycler.put(Object)
226: * @return always returns <code>true</code>
227: */
228: public synchronized boolean add(Object aObject) {
229: myObjects.add(aObject);
230: notify();
231:
232: return true;
233: }
234:
235: }
|