含gather/take的CALL-ME在hyper方法链中失效的问题及兼容方案问询

问题原因 #

• 当使用hyper时，迭代器会在多个worker线程并行处理元素。gather/take依赖动态变量$*GATHER关联take到对应的gather块，但每个worker线程的动态上下文独立，不会继承主线程的$*GATHER，因此执行take时会抛出“take without gather”错误。
• map是Raku内置的迭代器操作，专门针对并行迭代器做了适配：它会将元素处理逻辑分发到各个worker，同时维持必要的上下文，因此可以正常工作。

解决方案 #

要让CALL-ME同时支持串行惰性和并行场景，可以通过检测运行上下文，分支处理两种情况：

• 串行场景：保留gather/take维持惰性执行；
• 并行场景：改用map适配hyper/race上下文。

方案1：检测迭代器并行属性 #

直接判断输入迭代器是否为并行类型，针对性处理：

class Math {
    method CALL-ME(\iterable) {
        my $iterator = iterable.iterator;
        if $iterator.is-parallel {
            # 并行场景：用map适配hyper/race上下文
            iterable.map(&double)
        } else {
            # 串行场景：用gather/take维持惰性
            gather for $iterator { take double($_) }
        }
    }

    sub double($n) { $n * 2 }
}

my $d = Math.new;

# 串行惰性场景正常工作
(1,2,3).map(*+1).$d.map(*+1).say;

# hyper并行场景正常工作
(1,2,3).hyper.map(*+1).$d.map(*+1).say;

方案2：检测动态上下文变量 #

利用$*GATHER动态变量判断是否处于gather上下文，写法更简洁：

class Math {
    method CALL-ME(\iterable) {
        if $*GATHER.defined {
            # 串行惰性场景：直接take元素
            take double($_) for iterable
        } else {
            # 并行场景：用map处理
            iterable.map(&double)
        }
    }

    sub double($n) { $n * 2 }
}

内容的提问来源于stack exchange，提问作者pmqs