Apple平台下如何将Dispatch Queue关联到线程的Run Loop？

我正在将现有网络库移植到Apple平台，原实现采用单工作线程处理所有活动连接（封装原始套接字的对象），希望在Apple平台保留该设计。我未使用原始套接字，而是采用Apple的Network框架，该框架中的连接对象（nw_connection_t、nw_listener_t等）需要dispatch_queue_t对象来发送事件通知，我已创建该队列并传递给所有nw_...函数。

我的工作线程通过调用CFRunLoopGetCurrent获取（或创建）了关联的CFRunLoopRef实例，并在线程主循环中通过以下代码处理：

CFRunLoopRunInMode( kCFRunLoopDefaultMode, 0, true );

但我不清楚如何让线程的RunLoop处理我的dispatch_queue，我假设需要将两者关联，以便在工作线程中适时调用通知，请问该如何操作？

要将dispatch_queue_t与工作线程的CFRunLoop关联，核心是通过dispatch_source_t将队列事件桥接到RunLoop的事件源中，具体实现步骤如下：

1. 创建桥接用的Dispatch源 #

创建一个空的dispatch源，将其转换为CFRunLoop可识别的源并添加到工作线程的RunLoop中，这样当目标队列有事件时，RunLoop会被唤醒并处理队列任务：

// 桥接源的回调（仅用于触发RunLoop，无需额外逻辑）
static void runLoopDispatchSourceHandler(void *context) {}

// 你已创建的Network框架专用队列
dispatch_queue_t network_queue = ...;
// 工作线程的RunLoop实例
CFRunLoopRef worker_runloop = CFRunLoopGetCurrent();

// 创建空的信号源（用来触发RunLoop唤醒）
dispatch_source_t bridge_source = dispatch_source_create(DISPATCH_SOURCE_TYPE_SIGNAL, 0, 0, network_queue);
dispatch_source_set_event_handler(bridge_source, runLoopDispatchSourceHandler);
dispatch_resume(bridge_source);

// 将dispatch源转换为CFRunLoop源并添加到RunLoop
CFRunLoopSourceRef cf_bridge_source = dispatch_get_cfrunloop_source(bridge_source);
CFRunLoopAddSource(worker_runloop, cf_bridge_source, kCFRunLoopDefaultMode);

2. 调整工作线程的RunLoop循环逻辑 #

原代码的单次非阻塞调用无法持续处理事件，需要改成循环运行RunLoop，确保能及时处理队列中的Network框架回调：

// 自定义线程运行标志，根据业务逻辑控制线程退出
_Bool keep_running = true;

while (keep_running) {
    // 运行RunLoop，1秒超时（可根据需求调整），处理所有待触发事件
    CFRunLoopRunInMode(kCFRunLoopDefaultMode, 1.0, false);
}

// 线程退出前清理资源
CFRunLoopRemoveSource(worker_runloop, cf_bridge_source, kCFRunLoopDefaultMode);
dispatch_source_cancel(bridge_source);
dispatch_release(bridge_source);

3. 原理说明 #

• dispatch_get_cfrunloop_source将dispatch源转换为CFRunLoop源，添加到RunLoop后，当network_queue中有任务（如Network框架的连接事件、数据回调）时，dispatch源会自动唤醒RunLoop，让RunLoop在当前工作线程中执行队列任务。
• 这种方式不需要修改Network框架的队列配置，完美适配你单工作线程处理所有连接的设计，确保所有网络事件都在指定线程中处理。

内容的提问来源于stack exchange，提问作者James