Ruby 全局解释器锁 (GIL) - rb_thread_call_without_gvl

Question

我正在努力向 rb_thread_call_without_gvl 传递参数。这是我使用的简单代码。

#include <stdio.h>
#include <ruby.h>
#include <ruby/thread.h>

VALUE summa(VALUE self, VALUE x)
{
    double result;
    result = NUM2DBL(x) + NUM2DBL(x);

    printf("The sum in C is %f\n", result);
    return DBL2NUM(result);
}


VALUE no_gvl(VALUE self)
{
    double arg = 3.0;
    double *ptr = &arg;
    rb_thread_call_without_gvl(summa, ptr, NULL, NULL);
    return Qnil;
}

void Init_csum()
{
    VALUE myModule = rb_define_module("MyModule");
    VALUE myClass = rb_define_class_under(myModule, "MyClass", rb_cObject);
    rb_define_method(myClass, "summa", summa, 1);
    rb_define_method(myClass, "no_gvl", no_gvl, 0);
}

然后我尝试使用脚本 client.rb:

从 Ruby 调用扩展

require './csum'
obj = MyModule::MyClass.new # MyClass is defined in C
puts "The sum in R is " + obj.summa(7.0).to_s
puts obj.no_gvl

最后是我的 extconf.rb:

require 'mkmf'
extension_name = 'csum'
create_makefile(extension_name)

我是 C 的初学者，但我需要创建一个可以使用库而不受单个线程限制的扩展。看我的 .

当我 make 扩展时，我收到一条警告说

warning: incompatible pointer types passing 'VALUE (VALUE, VALUE)' to parameter of type 'void *(*)(void *)'

虽然我明白它说的是什么，但我看不出如何修复它。我应该忽略它吗？另外，当我运行 client.rb 调用 obj.no_gvl.

时出现分段错误

我在 Mac OSX 10.10.5 上使用 Ruby 2.0.0-p247 到 rbenv.

Answer 1

如果你还没有看过它，the source for rb_thread_call_without_gvl includes some documentation. (I’ve linked to the version that you’re using, but that’s a pretty old Ruby，你应该尽可能地看看更新。这个 API 在当前版本中是相同的，至少到 2.3.1。）

函数原型如下：

void *rb_thread_call_without_gvl(void *(*func)(void *), void *data1,
             rb_unblock_function_t *ubf, void *data2);

被调用的函数应该接受单个 void * 参数和 return void *，即它是一个普通的 C 函数，不是一个实现 Ruby 方法的 C 函数，正如您在示例中所使用的那样。事实上，它不能实现 Ruby 方法，因为这样做意味着访问受 GVL 保护的结构。

要使用它，您需要将要在没有锁定的情况下执行的代码移动到具有正确接口的函数中，并且不使用任何 Ruby API。这是一个示例（基于您自己的），它创建了一个 Ruby 方法，该方法将传递给它的参数加倍，并且在没有 GVL 的情况下完成工作：

#include <stdio.h>
#include <ruby.h>
#include <ruby/thread.h>

// The function that does the work, accepts void* and returns void*
void* doubleArg(void* x) {
    // Unpack the arg and cast back to double.
    double val = *(double*)x;
    double result = val + val;
    printf("The sum in C is %f\n", result);

    // If you wanted you could wrap up some data here to return to
    // Ruby land.
    return NULL;
}

// The function implementing the Ruby method
VALUE double_no_gvl(VALUE self, VALUE arg) {
    // First wrap up the input as a pointer.
    // You'll probably want to do some checking on the type of the 
    // argument here too.
    double argAsDouble = NUM2DBL(arg);
    double *ptr = &argAsDouble;

    // Now call the function without the GVL.
    // It might be worth looking into providing
    // an ubf function here too.
    rb_thread_call_without_gvl(doubleArg, ptr, NULL, NULL);
    return Qnil;
}

void Init_csum() {
    VALUE myModule = rb_define_module("MyModule");
    VALUE myClass = rb_define_class_under(myModule, "MyClass", rb_cObject);
    rb_define_method(myClass, "double_no_gvl", double_no_gvl, 1);
}

您可以使用如下脚本调用它：

require './csum'
obj = MyModule::MyClass.new
obj.double_no_gvl(3.9)

Ruby 全局解释器锁 (GIL) - rb_thread_call_without_gvl

Ruby Global Interpreter Lock (GIL) - rb_thread_call_without_gvl

c

ruby

gil

ruby-c-extension