multithreading - 从多线程调用 uv_write，它的回调永远不会被调用

Question

我已经阅读了 libuv 中的 tcp-echo-server.c 示例，现在我正在基于该示例编写一个小型多线程 tcp 服务器。

我在主线程中使用了uv_default_loop来接受连接，并将新连接放入列表中。

// main thread
    uv_ip4_addr("0.0.0.0", DEFAULT_PORT, &addr);

    uv_tcp_bind(&server, (const struct sockaddr*)&addr, 0);
    int r = uv_listen((uv_stream_t*) &server, DEFAULT_BACKLOG, OnConnectionCallback);
    if (r)
    {
        ERROR("Listen error %s", uv_strerror(r));
        return;
    }
    uv_run(loop, UV_RUN_DEFAULT);

在第二个线程中，我向我拥有的所有连接广播一条消息。

// second thread

    write_req_t *req = (write_req_t*) malloc(sizeof(write_req_t));
    req->buf = uv_buf_init((char *)buffer->data(), buffer->size());
    int r = uv_write((uv_write_t*) req, (uv_stream_t *)this->uv, &req->buf, 1, write_callback);
    if (r)
    {
        ERROR("uv_write error: %s", uv_strerror(ret));
    }

接受连接有效，从客户端读取有效，但写入部分无效。没有报告错误代码，但它的回调从未被触发。

我浏览了文档，但还找不到任何线索。我错过了什么？

顺便说一下，我使用的是 std::thread，而不是 libuv 中的线程 api。

Answer 1

libuv 不是线程安全的，因此您需要始终从运行它的同一线程访问循环。如果您想从另一个线程推送某些内容，您需要使用 uv_async_send 函数，如下所示。

uv_loop_t loop;
uv_async_t async;
...
uv_async_init(loop, &async, [](uv_async_t* handle) {
  ...
  // call uv_write or any uv functions
});
uv_async_send(async);