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

uv_write 是 libuv 库中的一个函数，用于异步地将数据写入到一个流（stream）中。libuv 是一个跨平台的异步 I/O 库，常用于 Node.js 的底层实现。当从多线程环境调用 uv_write 时，可能会遇到回调函数永远不会被调用的问题。以下是关于这个问题的基础概念、原因分析以及解决方案。

基础概念

libuv: 一个支持跨平台的异步 I/O 库，提供了事件循环、异步 TCP/UDP、文件系统操作等功能。
uv_write: libuv 中的一个函数，用于异步写入数据到流。
回调函数: 在异步操作完成后，用于处理结果的函数。

原因分析

线程安全问题: libuv 的事件循环（event loop）通常在一个单独的线程中运行。如果在其他线程中直接调用 uv_write，可能会导致竞态条件，使得事件循环无法正确处理写入操作。
事件循环阻塞: 如果事件循环被阻塞，它将无法处理任何异步操作，包括 uv_write 的回调。
资源泄漏: 如果在多线程环境中不正确地管理资源，可能会导致内存泄漏或其他资源问题，从而影响回调的执行。

解决方案

1. 使用 `uv_queue_work`

uv_queue_work 可以将工作项排队到事件循环线程中执行，从而避免直接在多线程环境中调用 uv_write。

void write_work(uv_work_t *req) {
    uv_stream_t *stream = req->data;
    uv_buf_t buf;
    buf.base = "hello";
    buf.len = 5;
    uv_write((uv_write_t *)req, stream, &buf, 1, write_done);
}

void write_done(uv_write_t *req, int status) {
    if (status < 0) {
        fprintf(stderr, "Write error %s\n", uv_strerror(status));
    }
    free(req);
}

void async_write(uv_stream_t *stream) {
    uv_work_t *req = (uv_work_t *)malloc(sizeof(uv_work_t));
    req->data = stream;
    uv_queue_work(uv_default_loop(), req, write_work, write_done);
}

2. 使用线程池

libuv 提供了一个线程池，可以通过 uv_threadpool_queue_work 将任务排队到线程池中执行。

void write_work(uv_work_t *req) {
    uv_stream_t *stream = req->data;
    uv_buf_t buf;
    buf.base = "hello";
    buf.len = 5;
    uv_write((uv_write_t *)req, stream, &buf, 1, write_done);
}

void write_done(uv_write_t *req, int status) {
    if (status < 0) {
        fprintf(stderr, "Write error %s\n", uv_strerror(status));
    }
    free(req);
}

void async_write(uv_stream_t *stream) {
    uv_work_t *req = (uv_work_t *)malloc(sizeof(uv_work_t));
    req->data = stream;
    uv_threadpool_queue_work(uv_default_loop(), req, write_work, write_done);
}

3. 确保事件循环不被阻塞

确保事件循环线程不被长时间运行的任务阻塞。可以使用 uv_async_send 来通知事件循环处理某些任务。

uv_async_t async;

void async_cb(uv_async_t *handle) {
    // 处理异步任务
}

void init_async() {
    uv_async_init(uv_default_loop(), &async, async_cb);
}

void trigger_async() {
    uv_async_send(&async);
}