* @brief Trigger the pipeline stage term step. * * This can be called from multi-threaded code. The first thread to hit this will process the * work pool termination. Caller must have called @c wait() prior to calling this function to * ensure that processing is complete. * * @param term_func Callable which executes the stage termination. */
| 313 | * @param term_func Callable which executes the stage termination. |
| 314 | */ |
| 315 | void term(std::function<void(void)> term_func) |
| 316 | { |
| 317 | std::lock_guard<std::mutex> lck(m_lock); |
| 318 | if (!m_term_done) |
| 319 | { |
| 320 | term_func(); |
| 321 | m_term_done = true; |
| 322 | } |
| 323 | } |
| 324 | }; |
| 325 | |
| 326 | /** |
no outgoing calls
no test coverage detected