On Fri, Aug 21, 2020 at 01:46:45AM +0800, Du Kaitian wrote:

On Thu, Aug 20, 2020 at 05:03:53PM +0800, Tong Qunfeng wrote:

...

background: a group of task (associate with same uuid), need blocked until special condition is meet.

implementation: create a Fiber for the uuid, when the condition is meet, let the Filber run (== this Fiber will dead). if the condition is not meet, then keep waiting (== block)

这个是为了多级 启动测试，或者同步任务提供的么，我们可以讨论一下这个逻辑 谢谢 jimmy

是的，多机同步等待可以用这个来辅助同步（未完成同步目标前都block等待）。 这是一个通用的 block_until_finished 逻辑， 同一个uuid可以 同步等待 1个“事件” 的true逻辑。

...

Signed-off-by: Tong Qunfeng <tongqunfeng@huawei.com> --- src/lib/block_helper.cr | 42 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 42 insertions(+) create mode 100644 src/lib/block_helper.cr

diff --git a/src/lib/block_helper.cr b/src/lib/block_helper.cr new file mode 100644 index 0000000..db84505 --- /dev/null +++ b/src/lib/block_helper.cr @@ -0,0 +1,42 @@ +# SPDX-License-Identifier: MulanPSL-2.0+ + +# helper for (task) block +class BlockHelper + + def initialize + @block_helper = Hash(String, Fiber).new + end + + # waiting untill special uuid's task is finished + # - yield (block) returns false, all uuid's task will block + # - yield returns true, then all uuid's task will continue + # + # examples: + # block_helper = BlockHelp.new # global instance + # + # # fiber-A call below code (checkfile: function / variable) + # # when "checkfile == fase", then fiber-A blocked + # # fiber-B call below code too + # # when "checkfile == true", then fiber-A and B continues + # block_helper.block_until_finished("1") { checkfile } + # + def block_until_finished(uuid) + if @block_helper[uuid]? + fiber = @block_helper[uuid] + else + fiber = Fiber.new { puts "uuid {#{uuid}} finished" } + @block_helper[uuid] = fiber + end + + if yield == true + spawn fiber.run + end + + until fiber.dead? + Fiber.yield + end + + @block_helper.delete(uuid) + end + +end -- 2.23.0

-- Thanks. chief <tongqunfeng@huawei.com>