16

我创建了一个专用于 libuv 运行循环的新线程。线程函数看起来像这样：

void thread_function()
{
  uv_loop_t *loop = uv_loop_new();
  uv_ref( loop );
  uv_run( loop );
}

ref 计数器增量使线程保持活动状态并处于处理 libuv 事件的状态。我希望能够通过uv_unref在主线程上执行来导致运行循环结束，从而导致线程退出。

但是，在检查uv_ref源代码时，我没有看到任何保证在并发访问期间对引用计数器变量的访问将同步。此外，在运行循环期间，我没有看到任何放弃对操作系统的控制的 yield 调用，这意味着程序将无法与其他进程很好地协作。

这让我相信我没有以正确的方式使用 libuv。如果有人可以解释我做错了什么，那就太好了！

4

1 回答 1

38

不，libuv 以这种方式不是线程安全的。您应该使用 uv_async 来指示循环退出。uv_async 是 libuv 拥有的唯一线程安全工具。

它看起来像这样：

uv_async_t exit_handle;

void exit_async_cb(uv_async_t* handle, int status) {
  /* After closing the async handle, it will no longer keep the loop alive. */
  uv_close((uv_handle_t*) &exit_handle, NULL);
}

void thread_function() {
  uv_loop_t *loop = uv_loop_new();
  /* The existence of the async handle will keep the loop alive. */
  uv_async_init(loop, &exit_handle, exit_async_cb);
  uv_run(loop);
}

现在从另一个线程，您可以通过调用来指示此循环退出

uv_async_send(&exit_handle);

您需要注意不要uv_async_send()在其他线程完成设置循环和 uv_async 句柄之前调用。最新版本的 libuv 包括您可以使用的uv_barrier同步原语；但是 Node.js 0.8 附带的 libuv 版本尚不支持此功能，因此您可能需要使用 pthread 工具来完成此工作。

在旁注中，您似乎正在调用uv_ref并uv_unref使用循环引用作为参数。在最近的 libuv 版本中，这已经改变，你现在应该uv_ref和uv_unref一个特定的句柄。详见uv.h。 _

于 2012-12-12T16:47:28.827 回答