You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by lc...@apache.org on 2021/10/18 23:27:07 UTC

[beam] 01/01: [BEAM-13015] Implement a simplified cancellable blocking queue with similar semantics to ArrayBlockingQueue.

This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 70ac565ea71f247fbe545489a5916ed058f4ddac
Merge: abe3aa7 d0253ed
Author: Lukasz Cwik <lu...@gmail.com>
AuthorDate: Mon Oct 18 16:26:01 2021 -0700

    [BEAM-13015] Implement a simplified cancellable blocking queue with similar semantics to ArrayBlockingQueue.

 .../org/apache/beam/sdk/fn/CancellableQueue.java   | 145 ++++++++++++++
 .../apache/beam/sdk/fn/CancellableQueueTest.java   | 213 +++++++++++++++++++++
 2 files changed, 358 insertions(+)