148 |
|
* Most mechanics are handled by BufferedSubscription. This class |
149 |
|
* mainly tracks subscribers and ensures sequentiality, by using |
150 |
|
* locks across public methods, to ensure thread-safety in the |
151 |
< |
* presence of multiuple sources and maintain acquire-release |
151 |
> |
* presence of multiple sources and maintain acquire-release |
152 |
|
* ordering around user operations. However, we also track whether |
153 |
|
* there is only a single source, and if so streamline some buffer |
154 |
|
* operations by avoiding some atomics. |