#include <iostream>
using std::cout;
using std::endl;
#include <pthread.h>
#include <unistd.h>
#include <sys/syscall.h>
#include <sstream>

#include "TParticle.h"
#include "TClonesArray.h"

pthread_mutex_t rootm = PTHREAD_MUTEX_INITIALIZER;

void* a_func(void* aVal) {

  TClonesArray* ca=new TClonesArray("TParticle",1000);
  for(int i=0;i<50;++i){
    // adding this mutex doesn't help
    //    if(pthread_mutex_lock(&rootm)==0){
    new((*ca)[i]) TParticle();
    // pthread_mutex_unlock(&rootm);
    // }
  }
  cout<<"exiting thread "<<ca->GetEntries()<<endl;
  
  // adding this mutex doesn't help
  //if(pthread_mutex_lock(&rootm)==0){
  ca->Clear("C");
  delete ca;
  //pthread_mutex_unlock(&rootm);
  // }
  

  //ca->Clear("C");
  return (void*)NULL;
}

int main(int argc,char** argv) {
  if ( argc<2 ) {
    cout<<"usage: "<<argv[0]<<" num-threads"<<endl;
    return 1;
  }
  int nt = atoi(argv[1]);
  pthread_t * tid = new pthread_t[nt];
  double * idxs = new double[nt];
  cout<<"Creating "<<nt<<" threads"<<endl;
  for ( int idx = 0 ; idx < nt ; idx++ ) {
    idxs[idx]=(double)idx;
    pthread_attr_t attr;
    pthread_attr_init(&attr);
    pthread_create( &(tid[idx]) , &attr, a_func, idxs + idx );
  }
  for ( int idx=0; idx < nt ; idx++ ) {
    pthread_join(tid[idx],NULL);
  }
  cout<<"Exit!"<<endl;
  return 0;
}