Update of /var/cvs/applications/commandserver/src/org/mmbase/util
In directory
james.mmbase.org:/tmp/cvs-serv25982/applications/commandserver/src/org/mmbase/util
Modified Files:
CommandServer.java
Log Message:
Cleaned the code a little
Added some generic stuff for function and datatypes
See also:
http://cvs.mmbase.org/viewcvs/applications/commandserver/src/org/mmbase/util
Index: CommandServer.java
===================================================================
RCS file:
/var/cvs/applications/commandserver/src/org/mmbase/util/CommandServer.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -b -r1.1 -r1.2
--- CommandServer.java 7 Sep 2006 12:33:47 -0000 1.1
+++ CommandServer.java 3 Feb 2008 17:33:56 -0000 1.2
@@ -48,7 +48,7 @@
*
* @author Michiel Meeuwissen
* @since MMBase-1.8.2
- * @version $Id: CommandServer.java,v 1.1 2006/09/07 12:33:47 michiel Exp $
+ * @version $Id: CommandServer.java,v 1.2 2008/02/03 17:33:56 nklasens Exp $
*/
@@ -84,7 +84,7 @@
}
};
- final static Executor threads = new ThreadPoolExecutor(THREADS, 10 *
THREADS, 5 * 60, TimeUnit.SECONDS, new ArrayBlockingQueue(500), factory);
+ final static Executor threads = new ThreadPoolExecutor(THREADS, 10 *
THREADS, 5 * 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(500),
factory);
// copy job
public static class Copier implements Runnable {
@@ -227,7 +227,7 @@
String host = args.length > 1 ? args[0] : "localhost";
int port = args.length == 1 ? Integer.parseInt(args[0]) :
Integer.parseInt(args[1]);
- final Executor socketThreads = new ThreadPoolExecutor(THREADS,
THREADS, 5 * 60, TimeUnit.SECONDS, new LinkedBlockingQueue(), factory);
+ final Executor socketThreads = new ThreadPoolExecutor(THREADS,
THREADS, 5 * 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(),
factory);
ServerSocket server = new ServerSocket();
SocketAddress address = new InetSocketAddress(host, port);
server.bind(address);
_______________________________________________
Cvs mailing list
[email protected]
http://lists.mmbase.org/mailman/listinfo/cvs
