/*
@author  j.n.magee 14/08/98
*/
package concurrency.primes;

import concurrency.connector.*;

class Generator extends Thread {
  private PrimesCanvas display;
  private Pipe out;
  static int MAX = 50;

  Generator(Pipe c, PrimesCanvas d)
    {out=c; display = d;}

  public void run() {
    try {
      for (int i=2;i<=MAX;++i) {
        display.print(0,i);
        out.put(new Integer(i));
        sleep(500);
      }
      display.print(0,Primes.EOS);
      out.put(new Integer(Primes.EOS));
    } catch (InterruptedException e){}
  }
}