package horstmann.ch09_queue1;
/**
   An action that repeatedly inserts a greeting into a queue.
 */
public class Producer implements Runnable
{
  /**
      Constructs the producer object.
      @param aGreeting the greating to insert into a queue
      @param aQueue the queue into which to insert greetings
      @param count the number of greetings to produce
   */
  public Producer(String aGreeting, BoundedQueue<String> aQueue, int count)
  {
    greeting = aGreeting;
    queue = aQueue;
    greetingCount = count;
  }

  public void run()
  {
    try
    {
      int i = 1;
      while (i <= greetingCount)
      {
        if (!queue.isFull())
        {
          queue.add(i + ": " + greeting);
          i++;
        }
        Thread.sleep((int) (Math.random() * DELAY));
      }
    }
    catch (InterruptedException exception)
    {
    }
  }

  private String greeting;
  private BoundedQueue<String> queue;
  private int greetingCount;

  private static final int DELAY = 10;
}