class AcceptRunner implements Runnable {
   private boolean listening = true;
   public void run() {
      ServerSocket socket = new ServerSocket(1234);
      Socket clientSocket;

      while (listening) {
         clientSocket = socket.accept();
         new Thread(new ClientChannel(socket)).start();
      }
   }
}


class ClientChannel implements Runnable {
   private Socket socket;
   private BufferedReader reader;

   public ClientChannel(Socket socket) {
      this.socket = socket;
      this.reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
   }

   public void run() {
      String buffer;
      while (!socket.isClosed()) {
         buffer = reader.readLine();

         // send data for processing
      }
   }

   public void send(String data) {
      socket.getOutputStream().write(data.getBytes());
   }
}