multithreading - raku 在具有不同参数的线程中调用相同的函数

Question

我记得在大学时代，线程共享资源和内存。我不知道 Raku 线程实现的细节，但是如果同时多个线程使用不同的参数调用同一个全局函数，它们是否会相互干扰，因为全局函数是一个由所有线程共享的单个代码块线程？例如，这个例子没有显示干扰，但是一些复杂的代码呢？

sub add ($a, $b) { $a + $b };
for 1..100 { start { sleep 1.rand; say "I am $_, {add($_, 1000)}"; } };

Answer 1

你不必担心同时从多个线程访问一个全局函数，原则上:参数是按值传递的，参数是函数的词法。

我能想到一个异常(exception):使用 state在这样的函数中的变量。在初始化状态变量时存在已知的竞争条件，更新形式为 $foo++。同时从多个线程运行时很可能会错过增量。例如。:

my int $a;
await (^10).map: { start { $a++ for ^100000 } }
say $a;  # 893127

又名，不是 1000000你会期待的。幸运的是，为了处理这种情况，我们有原子整数:

my atomicint $a;
await (^10).map: { start { $a⚛++ for ^100000 } }
say $a;  # 1000000

但这只是炫耀，而不是直接回答您的问题:-)

如果您有一段代码要确保一次只执行一个线程，您可以使用 Lock和 protect方法；

my $lock = Lock.new;  # usually in the mainline of a program
# ... code
$lock.protect: {
    # code executed by only 1 thread at a time
}

请注意，这被认为是“管道”，也就是仅在需要时才使用它，因为它会使您陷入死锁。