package lab8multiplethread;

import java.util.*;



public class genConsumer extends Thread 
{
    private int maxConsumer;
    Vector list;
    private SharedBuffer V;
    public genConsumer(Vector l,SharedBuffer v,int maxConsumer) {
        this.maxConsumer=maxConsumer;
	this.list = l;
	this.V = v;
    }
    
    public void run()
    {
	int num = 0;
	for (int counter=1; counter<=maxConsumer; counter++) 
        {
            Consumer l = new Consumer("consumer" + counter,V);
	    list.addElement(l); //Store the consumers in this nice array
        }//END FOR LOOP
        num = 0;
        while (true)
        {
            Consumer currConsumer = (Consumer)list.elementAt(num);
            if (!currConsumer.isAlive())
            {
                currConsumer.run();
                //currConsumer.start();
            }
            if (num==list.size()-1)
            {
                num=0;
            }//ENDIF
            num++;
        }//WHILELOOP*/
    }
}