// File: IO6.java (Module 13)
//
// Author: Rahul Simha
// Created: Nov 18, 1998
// Modified: Nov 13, 2000.
//
// Concurrent Producer-Consumer with pipes and a buffer
// with a half-way flush.

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.io.*;


class Producer extends JFrame implements Runnable {

    JLabel L;     // A place to write stuff.
    OutputStream outStream;

    public Producer (OutputStream outStream)
    {
	// Store the reference to the output stream.
	this.outStream = outStream;

	// Create the frame.
	this.setSize (700,100);
	this.setLocation (0,100);
	this.setTitle ("Producer");

	Container cPane = this.getContentPane();
	// cPane.setLayout (new BorderLayout());

	// This is where we will write to.
	L = new JLabel ("");
	cPane.add (L, BorderLayout.CENTER);

	this.setVisible (true);
    }


    // Must implement the run() method.

    public void run ()
    {
	// Write 25 random bytes to the buffer.

	for (int i=1; i<=25; i++) {
	    // Create a random byte
	    byte k = (byte) UniformRandom.uniform (1, 100);

	    // Write to label first.
	    L.setText (L.getText() + " " + k);

	    // Write it to the screen.
	    System.out.println ("Producer: writing " + k);

	    // Write integer to buffer.
	    try {
		outStream.write (k);
		if (i == 12) outStream.flush ();
	    }
	    catch (IOException e) { System.out.println (e); }

	    // Sleep for a while.
	    try {
		Thread.sleep ((int)UniformRandom.uniform(100,1000));
	    } catch (InterruptedException e) { System.out.println (e); }
	}

	// Write EOF and close output stream.
	try {
	    outStream.write (-1);
	    outStream.close ();
	}
	catch (IOException e) { System.out.println (e); }

	L.setText (L.getText() + " Done!");
    }

}


class Consumer extends JFrame implements Runnable {

    JLabel L;     // Data similar to Producer.
    InputStream inStream;

    public Consumer (InputStream inStream)
    {
	this.inStream = inStream;

	this.setSize (700,100);
	this.setLocation (0, 200);
	this.setTitle ("Consumer");

	Container cPane = this.getContentPane();
	// cPane.setLayout (new BorderLayout());

	L = new JLabel ("");
	cPane.add (L, BorderLayout.CENTER);

	this.setVisible (true);
    }


    public void run ()
    {
	// Read byte values until EOF.

	while (true) {
	    // Get the next byte
	    int i = -1;
	    try {
		i = inStream.read ();
	    }
	    catch (IOException e) { System.out.println (e); }

	    // Extract byte.
	    byte k = (byte) i;

	    // Check if end-of-data.
	    if ( (i < 0) || (k < 0) ) break;

	    System.out.println ("Consumer: just read " + k);

	    // Write it on the frame.
	    L.setText (L.getText() + " " + k);

	    // Sleep for a while.
	    try {
		Thread.sleep ((int)UniformRandom.uniform(5,10));
	    }
	    catch (InterruptedException e) { System.out.println (e); }
	}

	L.setText (L.getText() + " Done!");
	try {
	    inStream.close ();
	}
	catch (IOException e) { System.out.println (e); }

    }

}



// This is an independent quit button to quit the application.

class QuitButton extends JFrame {

    public QuitButton ()
    {
	this.setSize (80,50);
	this.setLocation (0, 0);
	this.setTitle ("Quit button");

	Container cPane = this.getContentPane();
	// cPane.setLayout (new BorderLayout());

	JButton quitb = new JButton ("QUIT");
	quitb.setBackground (Color.red);
	quitb.addActionListener (
	    new ActionListener () {
		public void actionPerformed (ActionEvent a)
		{
		    System.exit (0);
		}
	    }
	);
	cPane.add (quitb, BorderLayout.CENTER);
	this.setVisible (true);
    }

}


public class IO6 {

    public static void main (String[] argv)
    {
	// Create an independent quit button.
	QuitButton q = new QuitButton ();

	try {
	    // Create the matching pipes.
	    PipedOutputStream pipeOut = new PipedOutputStream ();
	    PipedInputStream pipeIn = new PipedInputStream (pipeOut);
      
	    // Wrap a buffer around the Producer.
	    BufferedOutputStream bufOut = new BufferedOutputStream (pipeOut);

	    // Create a producer instance and thread. Pass the buffer in.
	    Producer p = new Producer (bufOut);
	    Thread pthread = new Thread (p);
      
	    // Create a consumer instance and thread.
	    Consumer c = new Consumer (pipeIn);
	    Thread cthread = new Thread (c);
      
	    // Start the threads.
	    pthread.start();
	    // At this time, all the data is sitting in the buffer.
	    // Flush it out.
	    bufOut.flush();

	    cthread.start();
	}
	catch (IOException e) { System.out.println (e); }
    }

}