java/src/pm/device/text/InputListener.java

@@ -3,33 +3,27 @@ package pm.device.text;
 import java.io.InputStream;
 import java.util.Scanner;
 
+import pm.Listener;
 import pm.Task;
 import pm.task.TaskManager;
 import pm.value.Action;
 import pm.value.Target;
 
-public class InputListener implements Runnable {
-    protected static final int SLEEP = 100;
-    
-    protected boolean run;
+public class InputListener extends Listener {
     protected Scanner input;
 
     public InputListener(InputStream inputStream) {
         input = new Scanner(inputStream);
     }
 
-    public void start() {
-        new Thread(this).start();
-    }
-
     public void run() {
         run = true;
         while (running()) {
-            String textinput = input.next().toUpperCase();
-            if(textinput != null) {
+            String string = input.next().toUpperCase();
+            if(string != null) {
                 try {
                     TaskManager.add(
-                        new Task(Action.valueOf(textinput), Target.APPLICATION));
+                        new Task(Action.valueOf(string), Target.APPLICATION));
                 } catch(IllegalArgumentException e) {}
             }
             try {
@@ -43,8 +37,4 @@ public class InputListener implements Runnable {
     protected boolean running() {
         return run && input.hasNext();
     }
-
-    public void stop() {
-        run = false;        
-    }
 }

java/src/pm/device/text/lan/SocketListener.java

@@ -6,11 +6,10 @@ import java.net.ServerSocket;
 import java.net.Socket;
 import java.util.ArrayList;
 
+import pm.Listener;
 import pm.device.text.InputListener;
 
-public class SocketListener implements Runnable {
-    protected boolean run;
-
+public class SocketListener extends Listener {
     protected ServerSocket server;
     protected ArrayList<InputListener> inputListenerList;
 
@@ -19,12 +18,7 @@ public class SocketListener implements Runnable {
         inputListenerList = new ArrayList<InputListener>();
     }
 
-    public void start() {
-        new Thread(this).start();
-    }
-
     public void run() {
-        run = true;
         while (run) {
             try {
                 Socket socket = server.accept();