package jdk.jfr.api.consumer.recordingstream;

import jdk.jfr.api.consumer.recordingstream.TestStart.StartEvent;

class EventProducer extends Thread {

    private final Object lock = new Object();

    private boolean killed = false;

    public void run() {

        while (true) {

            StartEvent s = new StartEvent();

            s.commit();

            synchronized (lock) {

                try {

                    lock.wait(10);

                    if (killed) {

                        return; // end thread

                    }

                } catch (InterruptedException e) {

                    // ignore

                }

            }

        }

    }

    public void kill()  {

        synchronized (lock) {

            this.killed = true;

            lock.notifyAll();

            try {

                join();

            } catch (InterruptedException e) {

            }

        }

    }

}