Unable to read from the Socket Input Stream in a multithreaded environment with wait and notify

[Mohamed Sanaulla]

I am using 2 threads- ReaderThread for reading from the Socket input stream and the WriterThread for writing to the socket output stream. Both of them work fine when am just writing to the stream and not reading from the stream. But when am also Reading from the input stream the program doesn't run further, it hangs.

Below is the code which does the writing- Its in the WriterThread class.

  try{
		Scanner consoleReader = new Scanner(System.in);
		String inst="";
		PrintWriter writer = new PrintWriter(client.getOutputStream(),true);
		while(true){
				synchronized(response){

					
					System.out.print("Enter something: ");
					System.out.flush();
					
					inst=consoleReader.nextLine();
					System.out.println(inst);
					instruction.setInstruction(inst);
					if(!instruction.getInstruction().equals("")){
						
						writer.print(instruction.getInstruction());
						writer.flush();
						response.notifyAll();	

						if(instruction.getInstruction().equalsIgnoreCase("end")){
							break;
						}
						response.wait();
						
					}
				}//End of response sync
		}//End of while
		}catch(IOException ioex){
			System.out.println("IO Exception caught in Writer Thread");
		}catch(InterruptedException iex){
			System.out.println("Writer thread interrupted");
		}  

The above code- Reads from the command line, writes it to the socket outputstream using the "writer" object.

Below is the code which reads from the stream- Its in the ReaderThread class

 try{		
		Scanner reader = new Scanner(client.getInputStream());
		String txtRead="";
		outer:
		while(true){
			synchronized(response){
				response.wait();
				System.out.println("Reader Running");
				
				while(reader.hasNext()){ //Line-Beg
					txtRead=reader.next();
					System.out.println("Received: "+txtRead);
					if(txtRead.equalsIgnoreCase("end")){
						response.notifyAll();
						break outer;
					}
				}//End of reader while, Line-End

				response.notifyAll();
			}//End of response sync
		}//End of while
		}catch(IOException ioex){
			System.out.println("IOException caught in ReaderThread");
		}
		catch(InterruptedException iex){
				System.out.println("Interrupted ReaderThread");
		}  

The above code does the reading from the Socket's input stream. The problem wit the above code is it waits indefinitely after printing- "Reader Running". But when i comment out the code from Line-Beg to Line-End it executes properly giving chance for the other WriterThread to write to the output stream. Why is it so?

Note: "response" is a common object which is being used for synchronization. Also am closing the "server socket" once the main method completed execution. Also the client socket is a "C" socket.

PS: Am not sure if this should be in Thread forum. Cause i dont see any problems with the "wait" and "notify" being used.