Geant4  10.03.p03
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
G4MTBarrier.cc
Go to the documentation of this file.
1 // ********************************************************************
2 // * License and Disclaimer *
3 // * *
4 // * The Geant4 software is copyright of the Copyright Holders of *
5 // * the Geant4 Collaboration. It is provided under the terms and *
6 // * conditions of the Geant4 Software License, included in the file *
7 // * LICENSE and available at http://cern.ch/geant4/license . These *
8 // * include a list of copyright holders. *
9 // * *
10 // * Neither the authors of this software system, nor their employing *
11 // * institutes,nor the agencies providing financial support for this *
12 // * work make any representation or warranty, express or implied, *
13 // * regarding this software system or assume any liability for its *
14 // * use. Please see the license in the file LICENSE and URL above *
15 // * for the full disclaimer and the limitation of liability. *
16 // * *
17 // * This code implementation is the result of the scientific and *
18 // * technical work of the GEANT4 collaboration. *
19 // * By using, copying, modifying or distributing the software (or *
20 // * any work based on the software) you agree to acknowledge its *
21 // * use in resulting scientific publications, and indicate your *
22 // * acceptance of all terms of the Geant4 Software license. *
23 // ********************************************************************
24 //
25 // $Id$
26 //
27 // ---------------------------------------------------------------
28 /*
29  * G4MTBarrier.cc
30  *
31  * Created on: Feb 10, 2016
32  * Author: adotti
33  */
34 
35 #include "G4MTBarrier.hh"
36 #include "G4AutoLock.hh"
37 
38 G4MTBarrier::G4MTBarrier(unsigned int numThreads ) :
39  m_numActiveThreads(numThreads),
40  m_counter(0),
41  m_mutex(G4MUTEX_INITIALIZER),
42  m_counterChanged(G4CONDITION_INITIALIZER),
43  m_continue(G4CONDITION_INITIALIZER)
44 {
45 #if defined(WIN32)
46  InitializeCriticalSection( &cs1 );
47  InitializeCriticalSection( &cs2 );
48 #endif
49 }
50 
52  //Step-1: Worker acquires lock on shared resource (the counter)
53 #ifndef WIN32
54  G4AutoLock lock(&m_mutex);
55 #else
56  EnterCriticalSection( &cs1 );
57 #endif
58  //Step-2: Worker increases counter
59  ++m_counter;
60  //Step-3: Worker broadcasts that the counter has changed
61  G4CONDITIONBROADCAST(&m_counterChanged);
62  //Step-4: Worker waits on condition to continue
63 #ifndef WIN32
64  G4CONDITIONWAIT(&m_continue,&m_mutex);
65 #else
66 # ifdef G4MULTITHREADED
67  G4CONDITIONWAIT(&m_continue,&cs1);
68 # endif
69  LeaveCriticalSection(&cs1);
70 #endif
71 }
72 
74  while (true)
75  {
76  //Step-2: Acquires lock on shared resource (the counter)
77 #ifndef WIN32
78  G4AutoLock lock(&m_mutex);
79 #else
80  EnterCriticalSection(&cs2);
81 #endif
82  //If the counter equals active threads, all threads are ready, exit the loop
83  if ( m_counter == m_numActiveThreads ) { break; }
84  //Step-3: Not all workers are ready, wait for the number to change
85  //before repeating the check
86 #ifdef WIN32
87 # ifdef G4MULTITHREADED
88  G4CONDITIONWAIT(&m_counterChanged,&cs2);
89 # endif
90  LeaveCriticalSection(&cs2);
91 #else
92  G4CONDITIONWAIT(&m_counterChanged,&m_mutex);
93 #endif
94  }
95 }
96 
98  //Step-4: re-aquire lock and re-set shared resource for future re-use
99  G4AutoLock lock(&m_mutex);
100  m_counter = 0;
101  G4CONDITIONBROADCAST(&m_continue);
102 }
103 
105  //Step-1: Master enters a loop to wait all workers to be ready
106  Wait();
107  //Done, all workers are ready, broadcast a continue signal
108  ReleaseBarrier();
109 }
110 
112  G4AutoLock l(&m_mutex);
113  m_counter = 0;
114 }
115 
116 unsigned int G4MTBarrier::GetCounter() {
117  G4AutoLock l(&m_mutex);
118  const unsigned int result = m_counter;
119  return result;
120 }
G4double G4ParticleHPJENDLHEData::G4double result
virtual void WaitForReadyWorkers()
Definition: G4MTBarrier.cc:104
#define G4CONDITIONWAIT(cond, mutex)
Definition: G4Threading.hh:191
#define G4MUTEX_INITIALIZER
Definition: G4Threading.hh:175
void ThisWorkerReady()
Definition: G4MTBarrier.cc:51
void ResetCounter()
Definition: G4MTBarrier.cc:111
unsigned int GetCounter()
Definition: G4MTBarrier.cc:116
void ReleaseBarrier()
Definition: G4MTBarrier.cc:97
void Wait()
Definition: G4MTBarrier.cc:73
#define G4CONDITIONBROADCAST(cond)
Definition: G4Threading.hh:192
#define G4CONDITION_INITIALIZER
Definition: G4Threading.hh:190