The Producer

The BufferWriter class

/**
 * @author jack
 */
public class BufferWriter extends Thread {
    private int n = 10;
    private int repeat = 10;
    private MessageBuffer buffer;
    BufferWriter(MessageBuffer b) {
        buffer = b;
        buffer.registerWriter();
    }
    public void generate() {
        for (int i = 0 ; i < n; i++)
            buffer.put(i);
    }
    public void run() {
        for (int i = 0; i < repeat ; i++ )
            generate();
        buffer.unregisterWriter();
    }
}