Producent.java

package rploetz.umk;

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

public class Producent implements Runnable
{
    private Queue q;

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

    public void run()
    {
        Random r = new Random();

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

            int element = r.nextInt();

            System.out.println("Wstawiam: " + element);

            q.put(element);
            q.licznik++;


        }
    }


}