Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Keep track of the number of synchronisations achieved | Joel Low | 2016-11-06 | 1 | -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 Fork | Joel Low | 2016-11-06 | 1 | -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. |