#include <QtCore>
#include "BlockingQueue.h"

BlockingQueue blockingQueue;

class Producer : public QThread

{

public:

    QString threadName;

    Producer(const QString &name) {threadName = name;}

protected:

    virtual void run()

    {

        qDebug() << "Producer" << threadName << "started.";

        for(int i=0; i<100; ++i)

        {

            msleep(5);

            QString val = threadName;

            val.append(" -> ");

            val.append(QString::number(i));

            blockingQueue.enqueue(val);

        }

    }

};

class Consumer : public QThread

{

protected:

    virtual void run()

    {

        qDebug() << "Consumer started.";

        Q_FOREVER

        {

            qDebug() << "Readed queque value: " << blockingQueue.dequeue();

        }

    }

};

int main(int argc, char *argv[])

{

    QCoreApplication a(argc, argv);

    Consumer *consumer = new Consumer();

    consumer->start();

    for (int i=0; i<100; ++i)

    {

        Producer *p = new Producer(QString::number(i).prepend("PROD "));

        p->start();

    }

    return a.exec();

}