thread println and read so that println has priori

Adapting Apache WeatherTelnet code, I'm working towards a MUD client, but am struggling with concurrent input/output. It's not possible to read and write simultaneously, of course.

For this application, out should have priority over in. If nothing is being written to java.lang.System.out then, and only then, should input from java.lang.System.in be read. I'm just not sure how to accomplish that because in and out are interwoven.

run and memory dump:

thufir@dur:~$ 
thufir@dur:~$ 
thufir@dur:~$ java -jar NetBeansProjects/WeatherTelnet/dist/WeatherTelnet.jar 
------------------------------------------------------------------------------
*               Welcome to THE WEATHER UNDERGROUND telnet service!            *
------------------------------------------------------------------------------
*                                                                            *
*   National Weather Service information provided by Alden Electronics, Inc. *
*    and updated each minute as reports come in over our data feed.          *
*                                                                            *
*   **Note: If you cannot get past this opening screen, you must use a       *
*   different version of the "telnet" program--some of the ones for IBM      *
*   compatible PC's have a bug that prevents proper connection.              *
*                                                                            *
*           comments: jmasters@wunderground.com                              *
------------------------------------------------------------------------------

Press Return to continue:
fgf
d
e
f





2013-08-30 14:13:49
Full thread dump Java HotSpot(TM) Client VM (23.25-b01 mixed mode):

"Thread-2" daemon prio=10 tid=0xa0595400 nid=0x1c60 runnable [0x9fcdf000]
   java.lang.Thread.State: RUNNABLE
    at java.net.SocketInputStream.socketRead0(Native Method)
    at java.net.SocketInputStream.read(SocketInputStream.java:150)
    at java.net.SocketInputStream.read(SocketInputStream.java:121)
    at java.io.BufferedInputStream.read1(BufferedInputStream.java:273)
    at java.io.BufferedInputStream.read(BufferedInputStream.java:334)
    - locked <0xa0af5740> (a java.io.BufferedInputStream)
    at java.io.BufferedInputStream.fill(BufferedInputStream.java:235)
    at java.io.BufferedInputStream.read(BufferedInputStream.java:254)
    - locked <0xa0afa1e0> (a org.apache.commons.net.telnet.TelnetInputStream)
    at org.apache.commons.net.telnet.TelnetInputStream.__read(TelnetInputStream.java:141)
    at org.apache.commons.net.telnet.TelnetInputStream.run(TelnetInputStream.java:611)
    at java.lang.Thread.run(Thread.java:724)

"DestroyJavaVM" prio=10 tid=0xb6b06400 nid=0x1c56 waiting on condition [0x00000000]
   java.lang.Thread.State: RUNNABLE

"Thread-1" prio=10 tid=0x9fd20400 nid=0x1c5f in Object.wait() [0x9fe79000]
   java.lang.Thread.State: WAITING (on object monitor)
    at java.lang.Object.wait(Native Method)
    - waiting on <0xa0afca50> (a [I)
    at java.lang.Object.wait(Object.java:503)
    at org.apache.commons.net.telnet.TelnetInputStream.read(TelnetInputStream.java:392)
    - locked <0xa0afca50> (a [I)
    at org.apache.commons.net.telnet.TelnetInputStream.read(TelnetInputStream.java:534)
    at java.io.BufferedInputStream.fill(BufferedInputStream.java:235)
    at java.io.BufferedInputStream.read(BufferedInputStream.java:254)
    - locked <0xa0afebc8> (a java.io.BufferedInputStream)
    at weathertelnet.WeatherTelnet.consoleOutput(WeatherTelnet.java:65)
    at weathertelnet.WeatherTelnet$2.run(WeatherTelnet.java:33)
    at java.lang.Thread.run(Thread.java:724)

"Thread-0" prio=10 tid=0x9fd1f000 nid=0x1c5e runnable [0xa045c000]
   java.lang.Thread.State: RUNNABLE
    at java.io.FileInputStream.readBytes(Native Method)
    at java.io.FileInputStream.read(FileInputStream.java:242)
    at java.io.BufferedInputStream.fill(BufferedInputStream.java:235)
    at java.io.BufferedInputStream.read(BufferedInputStream.java:254)
    - locked <0xa0a16d88> (a java.io.BufferedInputStream)
    at weathertelnet.WeatherTelnet.consoleInput(WeatherTelnet.java:47)
    at weathertelnet.WeatherTelnet$1.run(WeatherTelnet.java:22)
    at java.lang.Thread.run(Thread.java:724)

"Service Thread" daemon prio=10 tid=0xb6bc3400 nid=0x1c5c runnable [0x00000000]
   java.lang.Thread.State: RUNNABLE

"C1 CompilerThread0" daemon prio=10 tid=0xb6bc1400 nid=0x1c5b waiting on condition [0x00000000]
   java.lang.Thread.State: RUNNABLE

"Signal Dispatcher" daemon prio=10 tid=0xb6bbfc00 nid=0x1c5a waiting on condition [0x00000000]
   java.lang.Thread.State: RUNNABLE

"Finalizer" daemon prio=10 tid=0xb6b83c00 nid=0x1c59 in Object.wait() [0xa04fe000]
   java.lang.Thread.State: WAITING (on object monitor)
    at java.lang.Object.wait(Native Method)
    - waiting on <0xa0a05698> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135)
    - locked <0xa0a05698> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:151)
    at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:189)

"Reference Handler" daemon prio=10 tid=0xb6b82000 nid=0x1c58 in Object.wait() [0xa065d000]
   java.lang.Thread.State: WAITING (on object monitor)
    at java.lang.Object.wait(Native Method)
    - waiting on <0xa0a05270> (a java.lang.ref.Reference$Lock)
    at java.lang.Object.wait(Object.java:503)
    at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:133)
    - locked <0xa0a05270> (a java.lang.ref.Reference$Lock)

"VM Thread" prio=10 tid=0xb6b7c400 nid=0x1c57 runnable 

"VM Periodic Task Thread" prio=10 tid=0xb6bcd800 nid=0x1c5d waiting on condition 

JNI global references: 171

Heap
 def new generation   total 4928K, used 1299K [0xa0a00000, 0xa0f50000, 0xa5f50000)
  eden space 4416K,  29% used [0xa0a00000, 0xa0b44d90, 0xa0e50000)
  from space 512K,   0% used [0xa0e50000, 0xa0e50000, 0xa0ed0000)
  to   space 512K,   0% used [0xa0ed0000, 0xa0ed0000, 0xa0f50000)
 tenured generation   total 10944K, used 0K [0xa5f50000, 0xa6a00000, 0xb0a00000)
   the space 10944K,   0% used [0xa5f50000, 0xa5f50000, 0xa5f50200, 0xa6a00000)
 compacting perm gen  total 12288K, used 2060K [0xb0a00000, 0xb1600000, 0xb4a00000)
   the space 12288K,  16% used [0xb0a00000, 0xb0c030d0, 0xb0c03200, 0xb1600000)
No shared spaces configured.




^Cthufir@dur:~$ 
thufir@dur:~$ 
thufir@dur:~$ 
thufir@dur:~$

code:

package weathertelnet;

import static java.lang.System.in;
import static java.lang.System.out;
import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.net.SocketException;
import org.apache.commons.net.telnet.TelnetClient;

public final class WeatherTelnet implements Runnable {

    @Override
    public void run() {


        new Thread(new Runnable() {

            @Override
            public void run() {
                try {
                    consoleInput();
                } catch (IOException ex) {
                }
            }
        }).start();

        new Thread(new Runnable() {

            @Override
            public void run() {
                try {
                    consoleOutput();
                } catch (SocketException ex) {
                } catch (IOException ex) {
                }
            }
        }).start();
    }

    public void consoleInput() throws IOException {
        do {
            char ch = (char) in.read();
            StringBuilder s = new StringBuilder();
            s.append(ch);
            while (255 > ch && ch >= 0) {
                ch = (char) in.read();
                s.append(ch);
            }
            out.println("\tyour text\t"+ s);
        } while (true);        
    }

    public void consoleOutput() throws SocketException, IOException {
        TelnetClient tc;
        tc = new TelnetClient();
        tc.connect("rainmaker.wunderground.com", 3000);

        InputStream inputStream = tc.getInputStream();

        char ch = (char) inputStream.read();

        while (255 > ch && ch >= 0) {
            out.print(ch);
            ch = (char) inputStream.read();
        }
    }

    public WeatherTelnet() {
        run();
    }

    public static void main(String[] args) {
        new WeatherTelnet();
    }
}

*code is under the ASL, please:

The correct way to handle this is to hand it over to the utility class, and just import examples.util.IOUtil from Apache:

package weathertelnet;

import examples.util.IOUtil;
import java.io.IOException;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.Properties;
import org.apache.commons.net.telnet.TelnetClient;

public class WeatherTelnet {

    private TelnetClient telnetConnection = new TelnetClient();

    public WeatherTelnet() throws SocketException, IOException {
        System.out.println("weather telnet..");
        Properties props = PropertiesReader.getProps();
        InetAddress host = InetAddress.getByName(props.getProperty("host"));
        int port = Integer.parseInt(props.getProperty("port"));
        telnetConnection.connect(host, port);
        System.out.println("connected");
        IOUtil.readWrite(telnetConnection.getInputStream(), telnetConnection.getOutputStream(), System.in, System.out);
    }

    public static void main(String[] args) throws SocketException, IOException {
        System.out.println("main...");
        new WeatherTelnet();
    }
}