Eliminate benign race condition in DirectStreamObserver (#33419)
A dynamic race condition detector correct identifies an unsynchronized read-after-write between the field initializer and the first call of onNext. Additionally a minor refactor to make more clear what the increment/boundary conditions are here.
显示
- sdks/java/core/src/main/java/org/apache/beam/sdk/fn/stream/DirectStreamObserver.java 3 个添加, 2 个删除...a/org/apache/beam/sdk/fn/stream/DirectStreamObserver.java
- sdks/java/core/src/test/java/org/apache/beam/sdk/fn/stream/DirectStreamObserverTest.java 13 个添加, 10 个删除...g/apache/beam/sdk/fn/stream/DirectStreamObserverTest.java
加载中
想要评论请 注册 或 登录