* tests/threads/threadpooltest.java: Added test program.

diff --git a/tests/threads/threadpooltest.java b/tests/threads/threadpooltest.java
new file mode 100644 (file)
index 0000000..3094c96
--- /dev/null
+++ b/tests/threads/threadpooltest.java
@@ -0,0 +1,51 @@
+// Use with "nc localhost 8080 < /dev/null"
+// Idle threads are parked by the jsr166 framework and caused lots of CPU usage
+// before the addition of park/unpark to CACAO.
+
+import java.net.*;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.util.concurrent.Executor;
+import java.util.concurrent.Executors;
+import java.net.InetSocketAddress;
+
+public class threadpooltest {
+       private static final int NTHREADS = 3;
+       private static final Executor exec = Executors.newFixedThreadPool(NTHREADS);
+       
+       private static void handleRequest(Socket s) {
+               String ss = "hello";
+               try {
+                       if (Thread.currentThread().isInterrupted())
+                               ss += " (wasinterrupted)";
+                       ss += " " + Thread.currentThread().toString();
+                       PrintWriter pw = new PrintWriter(s.getOutputStream());
+                       //Thread.currentThread().interrupt();
+                       pw.println(ss);
+                       pw.flush();
+                       Thread.sleep(100);
+                       pw.println("closing");
+                       pw.flush();
+                       s.close();
+               } catch (InterruptedException e) {
+                       e.printStackTrace();
+               } catch (IOException e) {
+                       e.printStackTrace();
+               }
+       }
+
+       public static void main(String[] args) throws IOException {
+               ServerSocket socket = new ServerSocket();
+               socket.setReuseAddress(true);
+               socket.bind(new InetSocketAddress(8080));
+               while (true) {
+                       final Socket connection = socket.accept();
+                       Runnable task = new Runnable() {
+                               public void run() {
+                                       handleRequest(connection);
+                               }
+                       };
+                       exec.execute(task);
+               }
+       }
+}