TG4WorkerInitialization.cxx

Go to the documentation of this file.

//------------------------------------------------
// The Geant4 Virtual Monte Carlo package
// Copyright (C) 2014 Ivana Hrivnacova
// All rights reserved.
//
// For the licensing terms see geant4_vmc/LICENSE.
// Contact: root-vmc@cern.ch
//-------------------------------------------------
 
 
#include "TG4WorkerInitialization.h"
#include "TG4RunManager.h"
 
#include <RVersion.h>
#include <TVirtualMCApplication.h>
 
#include <G4AutoLock.hh>
#include <G4Threading.hh>
#include <G4Types.hh>
 
#ifdef G4MULTITHREADED
namespace
{
// Mutex to lock MCApplication::FinishRun
G4Mutex finishRunMutex = G4MUTEX_INITIALIZER;
// Mutex to lock deleting MC application
// G4Mutex deleteMutex = G4MUTEX_INITIALIZER;
// Mutex to lock FinishRun & deleting MC application
G4Mutex stopWorkerMutex = G4MUTEX_INITIALIZER;
} // namespace
#endif
 
//_____________________________________________________________________________
TG4WorkerInitialization::TG4WorkerInitialization()
  : G4UserWorkerInitialization()
{
}
 
//_____________________________________________________________________________
TG4WorkerInitialization::~TG4WorkerInitialization()
{
}
 
//
// public methods
//
 
//_____________________________________________________________________________
void TG4WorkerInitialization::WorkerRunStart() const
{
 
  // G4cout << "TG4WorkerInitialization::WorkerRunStart() " << G4endl;
 
  TG4RunManager::Instance()->LateInitialize();
#ifdef G4MULTITHREADED
  TVirtualMCApplication::Instance()->BeginRunOnWorker();
  // G4cout << "TG4WorkerInitialization::WorkerRunStart() end " << G4endl;
#endif
}
 
//_____________________________________________________________________________
void TG4WorkerInitialization::WorkerRunEnd() const
{
  // This method is called for each thread, when the local event loop has
  // finished but before the synchronization over threads.
 
  // G4cout << "TG4WorkerInitialization::WorkerRunEnd() " << G4endl;
 
#ifdef G4MULTITHREADED
  G4AutoLock lm(&finishRunMutex);
  TVirtualMCApplication::Instance()->FinishRunOnWorker();
  lm.unlock();
#endif
 
  // G4cout << "TG4WorkerInitialization::WorkerRunEnd() end " << G4endl;
}
 
//_____________________________________________________________________________
void TG4WorkerInitialization::WorkerStop() const
{
 
  // G4cout << "TG4WorkerInitialization::WorkerStop() " << G4endl;
 
#ifdef G4MULTITHREADED
  G4AutoLock lm(&stopWorkerMutex);
  delete TVirtualMCApplication::Instance();
  lm.unlock();
#endif
 
  // G4cout << "TG4WorkerInitialization::WorkerStop() end " << G4endl;
}