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;
}