---

/Go4ThreadManagerExample/TGo4TestThreadManager.cxx

Go to the documentation of this file.

//---------------------------------------------------------------
//        Go4 Release Package v2.10-5 (build 21005) 
//                      03-Nov-2005
//---------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//       Experiment Data Processing at DVEE department, GSI
//---------------------------------------------------------------
//
//Copyright (C) 2000- Gesellschaft f. Schwerionenforschung, GSI
//                    Planckstr. 1, 64291 Darmstadt, Germany
//Contact:            http://go4.gsi.de
//----------------------------------------------------------------
//This software can be used under the license agreements as stated
//in Go4License.txt file which is part of the distribution.
//----------------------------------------------------------------
#include "TGo4TestThreadManager.h"

#include <iostream.h>

#include "Go4Log/TGo4Log.h"
#include "TGo4TestRunnable.h"

TGo4TestThreadManager::TGo4TestThreadManager(const TGo4TestThreadManager &right)
   :TGo4ThreadManager(right)
{
  TRACE((15,"TGo4TestThreadManager::TGo4TestThreadManager copy ctor",__LINE__, __FILE__));
}

TGo4TestThreadManager::TGo4TestThreadManager (Text_t* name)
   :TGo4ThreadManager(name,kFALSE)
{
   TRACE((15,"TGo4TestThreadManager::TGo4TestThreadManager (Text_t* name) constructor",__LINE__, __FILE__));
   fxControlRunnable=new TGo4TestRunnable("ControlRunnable",this,1);
   TGo4TestRunnable* th1run= new TGo4TestRunnable("HistogramMaker1",this,4);
   TGo4TestRunnable* th2run= new TGo4TestRunnable("HistogramMaker2",this,4);
   //TGo4TestRunnable* th3run= new TGo4TestRunnable("dummy action 3",this,0);
   TGo4TestRunnable* th4run= new TGo4TestRunnable("Exceptiontester",this,6);
   TGo4TestRunnable* th5run= new TGo4TestRunnable("Service thread",this,0);

   Text_t* txtbuffer= new Text_t[fguTEXTLENGTH];
//   strcpy(txtbuffer,"WorkHandlerOf_");
//   strcat(txtbuffer,name);
//   fxWorkHandler= new TGo4ThreadHandler(txtbuffer,this);
   fxWorkHandler->NewThread("First Thread",th1run);
   fxWorkHandler->NewThread("Second Thread",th2run);
   fxWorkHandler->NewThread("Third Thread",th5run);
   fxWorkHandler->NewThread("Fourth Thread",th4run);
   fxWorkHandler->NewThread("Control",fxControlRunnable);
   cout << "thread manager: all threads added to handler"<<endl;
   delete txtbuffer;
   fxCanvas=new TCanvas(GetName(),"TestRunnable",1200,400);
   fxPad1= new TPad("Pad1","TestRunnablePad",0.02,0.02,0.48,0.83,33);
   fxPad2= new TPad("Pad2","TestRunnablePad",0.52,0.02,0.98,0.83,33);
   fxCanvas->cd();
   cout <<"canvas drawn"<<endl;
   fxPad1->Draw();
   fxCanvas->cd();
   fxPad2->Draw();
   cout <<"pads drawn"<<endl;
   fxCanvas->Modified();
   fxCanvas->Update();

   Launch();
}


TGo4TestThreadManager::~TGo4TestThreadManager()
{
   TRACE((15,"TGo4TestThreadManager::~TGo4TestThreadManager destructor",__LINE__, __FILE__));
   delete fxPad1;
   delete fxPad2;
   delete fxCanvas;
}


TGo4TestThreadManager & TGo4TestThreadManager::operator=(const TGo4TestThreadManager &right)
{
TRACE((15,"TGo4TestThreadManager::operator=",__LINE__, __FILE__));
if (&right!=this)
      {
         TRACE((14,"TGo4TestThreadManager::operator= processing copy",__LINE__, __FILE__));
         TGo4ThreadManager::operator=(right);
         // to be ommitted
         return *this;
      }
   else
      {
         // copy is already source object
         TRACE((14,"TGo4TestThreadManager::operator= source and destination objects are identical",__LINE__, __FILE__));
         return *this;
      }
}



Int_t TGo4TestThreadManager::TestAction ()
{
  TRACE((14,"TGo4TestThreadManager::TestAction",__LINE__, __FILE__));
  // no test action so far...
  return 0;
}

TCanvas* TGo4TestThreadManager::GetCanvas ()
{
   TRACE((12,"TGo4TestThreadManager::GetCanvas",__LINE__, __FILE__));
   return fxCanvas;
}

TPad* TGo4TestThreadManager::GetPad1 ()
{
   TRACE((12,"TGo4TestThreadManager::GetPad1",__LINE__, __FILE__));
   return fxPad1;
}

TPad* TGo4TestThreadManager::GetPad2 ()
{
   TRACE((12,"TGo4TestThreadManager::GetPad2",__LINE__, __FILE__));
   return fxPad2;
}

ClassImp(TGo4TestThreadManager)





//----------------------------END OF GO4 SOURCE FILE ---------------------

---