/*
	Copyright (C) 2004-2008 Grame

	This program is free software; you can redistribute it and/or modify
	it under the terms of the GNU General Public License as published by
	the Free Software Foundation; either version 2 of the License, or
	(at your option) any later version.

	This program is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
	GNU General Public License for more details.

	You should have received a copy of the GNU General Public License
	along with this program; if not, write to the Free Software
	Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.

*/

#include <stdio.h>
#include <sys/time.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#ifdef __APPLE__
#include "JackMachThread.h"
#endif

#include "JackPosixThread.h"
#include "JackMutex.h"


using namespace Jack;

struct LockedObject : public JackLockAble {

	JackThread* fThread;
    int fCount;
 	
	LockedObject():fCount(0)
	{}
    
    virtual ~LockedObject()
	{
        fThread->Kill();
		delete fThread;
	}
    
    void LockedMethod1()
    {   
        JackLock lock(this);
        fCount++;
        printf("LockedMethod1 self %x fCount %d\n", pthread_self(), fCount);
    }
    
    void LockedMethod2()
    {   
        JackLock lock(this);
        fCount--;
        printf("LockedMethod2 self %x fCount %d\n", pthread_self(), fCount);
    }
    
    void LockedMethod3()
    {   
        JackLock lock(this);
        fCount--;
        printf("LockedMethod3 self %x fCount %d\n", pthread_self(), fCount);
    }

};

struct TestThread : public JackRunnableInterface {

	JackThread* fThread;
    LockedObject* fObject;
    int fNum;
 	
	TestThread(LockedObject* obj, int num)
	{
        fThread = new JackMachThread(this);
        fObject = obj;
        fNum = num;
	    fThread->StartSync();
 	}

	virtual ~TestThread()
	{
        fThread->Kill();
		delete fThread;
	}
     
    bool Execute()
    {
		printf("TestThread Execute\n");
        switch (fNum) {
        
            case 1:
                fObject->LockedMethod1();
                break;
                
            case 2:
                fObject->LockedMethod2();
                break;
        
            case 3:
                fObject->LockedMethod3();
                break;
        };
   		
        usleep(fNum * 1000);
		return true;
    }
	
};

int main (int argc, char * const argv[])
{
    char c;
    
    LockedObject obj;
    TestThread th1(&obj, 1);
    TestThread th2(&obj, 2);
    TestThread th3(&obj, 3);
      
    while ((c = getchar()) != 'q') {}
    
}