Ballerina Swan Lake-如何交替等待一组充满活力的Ballerina未来价值观

Question

我需要编写一个ballerina util函数，该函数可以等待给定的一组未来值并返回结果，其中未来值的数量可以变化，如下面的pseudo源代码所示。

function getWaitResult(future[] futures) returns any|error {
return wait futures[0] | futures[1] | ... | futures[n];
}

使用Ballerina Swan Lake版本实现相同功能的最佳方法是什么？

Answer 1

由于您必须静态地提供每个未来的引用，我建议您生成更多的支架，并结合备用等待操作。

import ballerina/lang.runtime;
import ballerina/io;
import ballerina/random;
function waitHelper(future<any>[] fs) returns any|error {
match fs {
var [f] => {
return wait f;
}
var [f, x] => {
return wait f | x;
}
var [f, x, y] => {
return wait f | x | y;
}
var [f, x, y, ...r] => {
var rest = start waitHelper(r);
return wait f | x | y | rest;
}
}
}
function foo() returns int {
int r = checkpanic random:createIntInRange(10, 200);
io:println("waiting (ms)... ", r);
runtime:sleep((<decimal>r)/1000);
return r;
}
public function main() {
future<int>[] f = [];
foreach int i in 0...9 {
var r = start foo();
f.push(r);
}
any|error got = waitHelper(f);
io:println("Got: ", got);
}