package lab8multiplethread;

import java.util.*;




public class genProducer extends Thread 
{
    private int maxProducer;
    private Vector list;
    private SharedBuffer V;
    public genProducer(Vector l,SharedBuffer v, int maxProducer) {
        this.maxProducer = maxProducer;
	this.list = l;
	this.V = v;
    }
    public void run(){
	int num = 0;

        for (int counter=1; counter<=maxProducer; counter++) 
        {
            Producer l = new Producer("producer" + counter,V);          
	    list.addElement(l); //Store the consumers in this nice array
        }//END FOR LOOP
        num = 0;
        while (true)
        {
            Producer currProducer = (Producer)list.elementAt(num);
            if (!currProducer.isAlive())
            {
                currProducer.run();
                //currProducer.start();
            }
            num++;
            if (num==list.size())
            {
                //break;
                num=0;
            }//ENDIF
            
        }//WHILELOOP*/
    }
}