equal
deleted
inserted
replaced
138 |
138 |
139 // Wait for the last worker to signal the coordinator. |
139 // Wait for the last worker to signal the coordinator. |
140 _end_semaphore->wait(); |
140 _end_semaphore->wait(); |
141 |
141 |
142 // No workers are allowed to read the state variables after the coordinator has been signaled. |
142 // No workers are allowed to read the state variables after the coordinator has been signaled. |
143 assert(_not_finished == 0, err_msg("%d not finished workers?", _not_finished)); |
143 assert(_not_finished == 0, "%d not finished workers?", _not_finished); |
144 _task = NULL; |
144 _task = NULL; |
145 _started = 0; |
145 _started = 0; |
146 |
146 |
147 } |
147 } |
148 |
148 |