ThreadPool init

Author: sworleys

networking/ThreadPoolClient.java

@@ -0,0 +1,4 @@
+
+public class ThreadPoolClient {
+
+}

networking/ThreadPoolServer.java

@@ -0,0 +1,66 @@
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.concurrent.ExecutorService;
+
+// From http://tutorials.jenkov.com/java-multithreaded-servers/thread-pooled-server.html
+
+public class ThreadPoolServer implements Runnable {
+
+	protected ServerSocket serverSocket;
+	protected Thread runningThread;
+	protected ExecutorService threadPool;
+
+
+	protected int serverPort = 9000;
+	protected boolean isStopped = false;
+	
+	public ThreadPoolServer(int port, ExecutorService threadPool) {
+		this.serverPort = port;
+		this.threadPool = threadPool;
+	}
+
+	@Override
+	public void run() {
+		synchronized(this) {
+			this.runningThread = Thread.currentThread();
+		}
+		this.openServerSocket();
+		while (! this.isStopped()) {
+			Socket clientSocket = null;
+			try {
+				clientSocket = this.serverSocket.accept();
+			} catch (IOException e) {
+				if (this.isStopped()) {
+					break;
+				}
+				throw new RuntimeException("Error accepting client connection" + e);
+			}
+			this.threadPool.execute(new WorkerRunnable(clientSocket, "Thread Pooled Server"));
+		}
+		this.threadPool.shutdown();
+		System.out.println("Server Stopped");
+	}
+
+	public synchronized void stop() {
+		this.isStopped = true;
+		try {
+			this.serverSocket.close();
+		} catch (IOException e) {
+			throw new RuntimeException("Error closing server", e);
+		}
+	}
+
+	private synchronized boolean isStopped() {
+		return this.isStopped;
+	}
+
+	private void openServerSocket() {
+		try {
+			this.serverSocket = new ServerSocket(this.serverPort);
+		} catch (IOException e) {
+			throw new RuntimeException("Cannot open port " + this.serverPort + ":" + e);
+		}
+	}
+
+}

networking/WorkerRunnable.java

@@ -0,0 +1,34 @@
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.net.Socket;
+
+// Code used for testing my thread pool
+// From https://www.programcreek.com/java-api-examples/index.php?source_dir=Android_H264Stream-master/src/tw/jwzhuang/ipcam/server/WorkerRunnable.java
+public class WorkerRunnable implements Runnable {
+
+	 protected Socket clientSocket = null; 
+	 protected String serverText = null; 
+	 
+	 public WorkerRunnable(Socket clientSocket, String serverText) { 
+	  this.clientSocket = clientSocket; 
+	  this.serverText = serverText; 
+	 } 
+	 
+	 @Override 
+	 public void run() { 
+	  try { 
+	   InputStream input = clientSocket.getInputStream(); 
+	   OutputStream output = clientSocket.getOutputStream(); 
+	   long time = System.currentTimeMillis(); 
+	   output.write(("HTTP/1.1 200 OK\n\nWorkerRunnable: " 
+	     + this.serverText + " - " + time + "").getBytes()); 
+	   output.close(); 
+	   input.close(); 
+	   System.out.println("Request processed: " + time); 
+	  } catch (IOException e) { 
+	   // report exception somewhere. 
+	   e.printStackTrace(); 
+	  } 
+	 }
+}

rectangles/Rectangles.java

@@ -1,12 +1,17 @@
 
 import java.util.ArrayList;
+import java.util.concurrent.ExecutorService;
 
 import processing.core.PApplet;
 import processing.core.PShape;
 import processing.core.PVector;
 
 public class Rectangles extends PApplet {
 
+	private boolean isServer;
+	private ThreadPoolServer server;
+	private ThreadPoolClient client;
+	private ExecutorService threadPool;
 	private GameObj floor;
 	private GameObj ceiling;
 	private GameObj leftWall;
@@ -16,6 +21,10 @@ public class Rectangles extends PApplet {
 
 	private ArrayList<GameObj> objects = new ArrayList<GameObj>();
 
+	public Rectangles(boolean isServer) {
+		this.isServer = isServer;
+	}
+	
 	public void settings() {
 		size(640, 360);
 	}
@@ -51,6 +60,10 @@ public void setup() {
 
 		// TODO: This will need to be reworked for server-client
 		this.objects.add(this.rectangle);
+		
+		// Setup Server
+		this.server = new ThreadPoolServer(9000, threadPool);
+		new Thread(this.server).start();
 
 	}
 
@@ -77,6 +90,11 @@ public void draw() {
 
 	}
 
+	public void dispose() {
+		System.out.println("Stopping Server");
+		this.server.stop();
+	}
+	
 	public void keyPressed() {
 		if (key == CODED) {
 			if (keyCode == LEFT) {
@@ -95,7 +113,7 @@ public void keyPressed() {
 
 	public static void main(String[] args) {
 		String[] processingArgs = {"Rectangles"};
-		Rectangles sketch = new Rectangles();
+		Rectangles sketch = new Rectangles(args[0].toLowerCase() == "server");
 		PApplet.runSketch(processingArgs, sketch);
 	}
 }