#include <QtCore/QCoreApplication>

#include <QThread>
#include <QMutex>
#include <stdio.h>
#include <stdlib.h>
#include <iostream>

using namespace std;

class Producer : public QThread
{
public:
    void run();
    void setCh(char);
    void setShare(int *sh);
    void setOffset(int os);

private:
    //static int x = 0;
    char ch;
    int *shareData;
    int offset;
};

void Producer::setCh (char c)
{
    ch = c;
}

void Producer::setShare (int *sh)
{
    shareData = sh;
}

void Producer::setOffset(int os)
{
    offset = os;
}

void Producer::run()
{
    QMutex mut;

    int val;
    std::cout << "Inside Producer: " << ch <<endl;
    for (int i=0; i < 10000; i++)
    {
       mut.lock();
       val = *shareData;
       val = val + offset;
       *shareData = val;
       mut.unlock();

      //cout << endl;
    }
    cout << "Ending Producer: " << ch << endl;
}

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    int sharedValue = 0;

    Producer p1;
    p1.setCh('A');
    p1.setShare(&sharedValue);
    p1.setOffset(+1);

    Producer p2;
    p2.setCh('b');
    p2.setShare(&sharedValue);
    p2.setOffset(-1);

    std::cout<< "Before starts: "<< sharedValue << endl;

    p1.start();
    p2.start();

    p1.wait();
    p2.wait();
    std::cout<< "After waits: "<< sharedValue << endl;

    return a.exec();
}