Update talk.java to use ThreadPool.

Author: m0ver

WEB-INF/lib/struct-2.0.jar

@@ -38,7 +38,7 @@
 import org.tinystruct.dom.Element;
 import org.tinystruct.system.Authentication;
 import org.tinystruct.system.util.Base64;
-import org.tinystruct.system.util.URLFileLoader;
+import org.tinystruct.system.util.URLResourceLoader;
 
 import custom.objects.User;
 import custom.objects.article;
@@ -583,7 +583,7 @@ public static void main(String[]args) throws ApplicationException, IOException{
 
 		while(p <= 47) {
 			URL url = new URL("http://www.old-gospel.net/viewthread.php?tid=446&extra=page%3D1&page="+(p++));
-			URLFileLoader file = new URLFileLoader(url);
+			URLResourceLoader file = new URLResourceLoader(url);
 			file.setCharset("gbk");
 			String content = file.getContent().toString();
 			Matcher m = pattern.matcher(content);

src/tinystruct/examples/reading.java

@@ -24,10 +24,11 @@
 public class talk extends AbstractApplication {
 
   private static final long TIMEOUT = 200;
+  private static final int DEFAULT_POOL_SIZE = 3;
   protected final Map<String, Queue<Builder>> list = new ConcurrentHashMap<String, Queue<Builder>>();
   protected final Map<String, Queue<Builder>> meetings = new ConcurrentHashMap<String, Queue<Builder>>();
   protected final Map<String, List<String>> sessions = new ConcurrentHashMap<String, List<String>>();
-  private final ExecutorService service = Executors.newFixedThreadPool(3);
+  private ExecutorService service;
 
   @Override
   public void init() {
@@ -36,23 +37,25 @@ public void init() {
     this.setAction("talk/version", "version");
     this.setAction("talk/testing", "testing");
 
-    Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
-        @Override
-        public void run() {
-            service.shutdown();
-            while (true) {
-                try {
-                    System.out.println("Waiting for the service to terminate...");
-                    if (service.awaitTermination(5, TimeUnit.SECONDS)) {
-                      System.out.println("Service will be terminated soon.");
+    if (this.service != null) {
+      Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
+          @Override
+          public void run() {
+              service.shutdown();
+              while (true) {
+                  try {
+                      System.out.println("Waiting for the service to terminate...");
+                      if (service.awaitTermination(5, TimeUnit.SECONDS)) {
+                        System.out.println("Service will be terminated soon.");
                         break;
-                    }
-                } catch (InterruptedException e) {
-                  e.printStackTrace();
-                }
-            }
-        }
-    }));
+                      }
+                  } catch (InterruptedException e) {
+                    e.printStackTrace();
+                  }
+              }
+          }
+      }));
+    }
   }
 
   /**
@@ -97,7 +100,7 @@ public final String save(final Object meetingCode, final Builder builder) {
       this.meetings.notifyAll();
     }
 
-    service.execute(new Runnable(){
+    this.getService().execute(new Runnable(){
       @Override
       public void run() {
         synchronized(talk.this.meetings) {
@@ -117,6 +120,10 @@ public void run() {
     return builder.toString();
   }
 
+  private ExecutorService getService() {
+	return this.service!=null? this.service : Executors.newFixedThreadPool(DEFAULT_POOL_SIZE);
+  }
+
   /**
    * Poll message from the messages of the session specified sessionId.
    * @param sessionId
@@ -197,7 +204,7 @@ public boolean testing(final int n) throws ApplicationException {
     sess.add("{B}");
     this.sessions.put("[M001]", sess);
 
-    service.execute(new Runnable(){
+    this.getService().execute(new Runnable(){
       @Override
       public void run() {
         int i=0;
@@ -215,7 +222,7 @@ public void run() {
       }
     });
 
-    service.execute(new Runnable(){
+    this.getService().execute(new Runnable(){
       @Override
       public void run() {
         int i=0;
@@ -233,7 +240,7 @@ public void run() {
       }
     });
 
-    service.execute(new Runnable(){
+    this.getService().execute(new Runnable(){
       @Override
       public void run() {
         // TODO Auto-generated method stub
@@ -252,7 +259,7 @@ public void run() {
       }
     });
 
-    service.execute(new Runnable(){
+    this.getService().execute(new Runnable(){
       @Override
       public void run() {
         // TODO Auto-generated method stub