aboutsummaryrefslogtreecommitdiffstats
path: root/src/lib/utils/barrier.h
Commit message (Collapse)AuthorAgeFilesLines
* Keep track of the number of synchronisations achievedJoel Low2016-11-061-2/+6
| | | | | This allows wait() to be called immediately after sync() returns, even if not all of the waiting threads have awoken.
* Implement barriers for Threaded ForkJoel Low2016-11-061-0/+41
This commit introduces a concept of a barrier, where all threads must synchronise before continuing. Threaded Fork uses this to ensure that all input is consumed by each sink exactly once. Fixes #695.