Konsument.java

package rploetz.umk;

import java.util.logging.Level;
import java.util.logging.Logger;

public class Konsument implements Runnable
{
    private Queue q;

    public Konsument(Queue my_q)
    {
        q = my_q;
    }

    public void run()
    {
        while(true)
        {
            try
            {
                Thread.sleep(4000);
            }
            catch(InterruptedException ex)
            {
                Logger.getLogger(Producent.class.getName()).log(Level.SEVERE, (String)null);
            }

            System.out.println("Pobieram: " + q.get());
            q.licznik--;
        }
    }
}