The Consumer

The BufferReader class

/**
 * @author jack
 */
public class BufferReader extends Thread {
    private MessageBuffer buffer;
    BufferReader(MessageBuffer b) {
        buffer = b;
    }
    public void run() {
        int cnt = 0;
        while (true) {
            int i = buffer.get();
            if (i < 0)
                break;
            if (cnt++ >= 10) {
                System.out.println("");
                cnt = 1;
            }
            System.out.print(i + ",");
        }
        System.out.println("");
    }
}