Problem in Multi-thread application .

package Server;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;

// TODO: Auto-generated Javadoc
/**
 * The Class Server.
 */
public class Server {

	/** The reader. */
	BufferedReader reader;

	/** The data. */
	String data;

	/** The port. */
	private int port = 7898;

	/** The server socket. */
	private ServerSocket serverSocket;

	/** The socket. */
	private Socket socket;

	/** The input data. */
	String inputData;

	/** The map. */
	HashMap<Integer, Socket> map = new HashMap<Integer, Socket>();

	/** The writer. */
	PrintWriter writer;

	/** The client code. */
	int clientCode = 0;

	/**
	 * Instantiates a new server.
	 * 
	 * @param sa
	 *            the sa
	 */
	public Server(String sa) {

	}

	/**
	 * Instantiates a new server.
	 * @throws InterruptedException 
	 */
	public Server() throws InterruptedException {
		try {
			serverSocket = new ServerSocket(port);
			System.out.println("waiting For connection on this port " + " "
					+ port);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

		while (true) {
			try {
				socket = serverSocket.accept();

				Thread thread = new Thread(new ServerManager(socket));
				thread.start();
				thread.sleep(1000L);
			} catch (IOException e) {

				e.printStackTrace();
			}

		}
	}

	/**
	 * The main method.
	 * 
	 * @param args
	 *            the arguments
	 * @throws IOException
	 *             Signals that an I/O exception has occurred.
	 * @throws ClassNotFoundException
	 *             the class not found exception
	 * @throws InterruptedException
	 *             the interrupted exception
	 */
	public static void main(String[] args) throws IOException,
			ClassNotFoundException, InterruptedException {
		Server server = new Server();

		// server.invokingMethod();

	}

}

package Server;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.HashMap;
import java.util.Random;

// TODO: Auto-generated Javadoc
/**
 * The Class ServerManager.
 */
class ServerManager implements Runnable {

	/** The socket. */
	Socket socket = null;

	/** The map. */
	HashMap<Integer, Socket> map = new HashMap<Integer, Socket>();

	/** The input stream. */
	BufferedReader inputStream;

	/** The input. */
	BufferedReader input;

	/** The output stream. */
	BufferedWriter outputStream;

	/** The buffered writer. */
	BufferedWriter bufferedWriter;

	/** The data. */
	String data;

	/** The input data. */
	String inputData;

	/** The client code. */
	int clientCode = 0;

	/**
	 * Instantiates a new server manager.
	 * 
	 * @param clientSocket
	 *            the client socket
	 */
	public ServerManager(Socket clientSocket) {
		this.socket = clientSocket;
		Random random = new Random();
		clientCode = Math.abs(random.nextInt());
	}

	/**
	 * Instantiates a new server manager.
	 */
	public ServerManager() {

	}

	/**
	 * The Class ServerReader.
	 */
	class ServerReader implements Runnable {

		/** The input stream. */
		InputStream inputStream;

		/**
		 * Instantiates a new server reader.
		 * 
		 * @param inputStream
		 *            the input stream
		 */
		public ServerReader(InputStream inputStream) {
			this.inputStream = inputStream;
		}

		/*
		 * (non-Javadoc)
		 * 
		 * @see java.lang.Runnable#run()
		 */
		@Override
		public void run() {

			// When started keep seeking for socket input data
			while (true) {
				try {
					if (inputStream.available() > 0) {
						byte[] readData = new byte[inputStream.available()];
						System.out.println();
						inputStream.read(readData);
						System.out.println("Data from Client " + clientCode
								+ ": " + new String(readData));

					}
					Thread.sleep(1000L);
				} catch (IOException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		}

	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see java.lang.Runnable#run()
	 */
	public void run() {

		try {
			System.out.println("The Client with Code " + clientCode + ": "
					+ "Connected");

			Thread thread = new Thread(
					new ServerReader(socket.getInputStream()));

			thread.start();
			outputStream = new BufferedWriter(new OutputStreamWriter(
					socket.getOutputStream()));
			add(clientCode);

			data = dataFromConsole().toString();

			send(data);

		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	/**
	 * Adds the.
	 * 
	 * @param clientCode
	 *            the client code
	 */
	public void add(Integer clientCode) {

		map.put(clientCode, socket);
	}

	/**
	 * Send.
	 * 
	 * @param message
	 *            the message
	 * @throws IOException
	 *             Signals that an I/O exception has occurred.
	 * @throws ClassNotFoundException
	 *             the class not found exception
	 * @throws InterruptedException
	 *             the interrupted exception
	 */
	public void send(String message) throws IOException,
			ClassNotFoundException, InterruptedException {

		outputStream.write(message);
		outputStream.newLine();
		outputStream.flush();

	}

	/**
	 * Data from console.
	 * 
	 * @return the string
	 * @throws IOException
	 *             Signals that an I/O exception has occurred.
	 */
	public String dataFromConsole() throws IOException {
		input = new BufferedReader(new InputStreamReader(System.in));
		inputData = input.readLine();
		return inputData;
	}

	public void Disconnect() throws IOException {
		while (true) {

			input.close();
			outputStream.close();
			socket.close();
		}

	}
}