简介CSDN博客专家、《Android系统多媒体进阶实战》作者博主新书推荐《Android系统多媒体进阶实战》Android Audio工程师专栏地址Audio工程师进阶系列【原创干货持续更新中……】Android多媒体专栏地址多媒体系统工程师系列【原创干货持续更新中……】专题一 二AAOS车载系统AOSP14系统攻城狮入门视频实战课专题三Android14 Binder之HIDL与AIDL通信实战课专题四Android15快速自定义与集成音效实战课专题五Android15音频策略实战课专题六Android15音频性能实战课(无声/杂音/断音/爆音实战案例)人生格言人生从来没有捷径只有行动才是治疗恐惧和懒惰的唯一良药.更多原创,欢迎关注Android系统攻城狮文章目录1. 前言要点概括2. 应用场景与用法函数原型参数说明返回值应用场景3. 调用流程剖析3.1 核心步骤1. 准备底层 pw_loop2. 调用 pw_thread_loop_new_full3. 分配 Thread Loop 管理对象4. 处理底层 Loop5. 设置 Loop 名称6. 初始化 Listener 管理结构7. 返回 pw_thread_loop8. 启动 Thread Loop3.2 调用流程图3.3 Thread Loop创建生命周期图4. 实战应用案例5. 一句话总结1. 前言本篇目的Linux PipeWire 深度解析之pw_thread_loop_new_full调用流程与实战。要点概括核心功能使用指定的pw_loop创建一个pw_thread_loop对象。工作机制接口创建 Thread Loop 管理对象保存线程名称和属性并封装传入的底层pw_loop当loop为NULL时内部自动创建新的pw_loop。典型用途复用自定义 Loop、独立线程运行事件循环、PipeWire Core 管理、Stream 异步控制。pw_thread_loop_new_full()只完成 Thread Loop 对象创建不会立即启动工作线程。创建成功后需要调用pw_thread_loop_start()才会启动线程并运行底层事件循环。(PipeWire)2. 应用场景与用法pw_thread_loop_new_full()是 PipeWire Thread Loop 创建体系中的完整构造接口。普通的pw_thread_loop_new(name,props);由 Thread Loop 内部自动创建底层pw_loop。而pw_thread_loop_new_full(loop,name,props);允许应用传入一个已经创建的pw_loop再由 Thread Loop 对该 Loop 进行线程化封装。该接口用于使用指定的底层pw_loop、线程名称和属性创建pw_thread_loop。当传入的loop为NULL时接口会自动创建新的pw_loop当传入已有pw_loop时Thread Loop 直接封装并复用该对象。(PipeWire)函数原型structpw_thread_loop*pw_thread_loop_new_full(structpw_loop*loop,constchar*name,conststructspa_dict*props);参数说明loop:需要封装的底层 pw_loop 传入已有 pw_loop:复用应用创建的 Loop 传入NULL:内部自动创建新的 pw_loop name:Thread Loop 对应的线程名称 可以传入NULLprops:Thread Loop 属性字典 不需要额外属性时可以传入NULL返回值成功:返回新创建的 pw_thread_loop 指针 失败:返回NULL返回成功仅表示 Thread Loop 对象创建完成此时工作线程尚未启动。应用场景pw_thread_loop_new_full()常见应用场景主要有三类。第一类是复用应用已经创建的pw_loop。应用可能已经通过pw_loop_new()创建底层 Loop并注册了 I/O、Timer、Signal、Event 等事件源。此时可以把已有 Loop 传给pw_thread_loop_new_full()让该 Loop 后续运行在独立线程中。第二类是自定义 Thread Loop 属性。应用可以通过props传入线程相关属性再为 Thread Loop 指定清晰的线程名称便于日志分析、线程调试和多实例管理。第三类是 PipeWire Core 和 Stream 的异步管理。应用可以先创建并封装底层 Loop再获取pw_thread_loop_get_loop()返回的pw_loop用于创建pw_context、连接pw_core、创建pw_stream和注册事件回调最后调用pw_thread_loop_start()启动事件线程。3. 调用流程剖析3.1 核心步骤1. 准备底层 pw_loop应用可以先创建一个底层 Loopstructpw_loop*loop;looppw_loop_new(NULL);也可以不提前创建直接传入NULL2. 调用 pw_thread_loop_new_full应用执行structpw_thread_loop*thread_loop;thread_looppw_thread_loop_new_full(loop,pipewire-thread-loop,NULL);3. 分配 Thread Loop 管理对象接口内部为structpw_thread_loop分配内存用于保存底层 Loop、线程句柄、运行状态和 Listener 等信息。4. 处理底层 Loop当参数loop不为NULL时直接保存并封装已有 pw_loop当参数loop为NULL时调用 pw_loop_new(props) 创建新的 pw_loopPipeWire 内部会记录这个 Loop 是否由 Thread Loop 自己创建从而决定销毁 Thread Loop 时是否同时销毁底层 Loop。(GitHub)5. 设置 Loop 名称内部根据name参数设置底层 Loop 名称。当name不为NULL时使用应用指定的名称当name为NULL时使用默认名称 thread-loop6. 初始化 Listener 管理结构接口初始化 Thread Loop 内部的 Listener List为后续pw_thread_loop_add_listener()注册销毁等事件回调做准备。7. 返回 pw_thread_loop创建成功后返回structpw_thread_loop*此时只完成对象和同步运行环境的准备工作线程尚未启动。8. 启动 Thread Loop后续调用pw_thread_loop_start(thread_loop);PipeWire 创建工作线程在线程中执行pw_loop_enter() pw_loop_iterate() pw_loop_leave()从而让底层pw_loop在独立线程中持续运行。(PipeWire)3.2 调用流程图3.3 Thread Loop创建生命周期图4. 实战应用案例#includepipewire/pipewire.h// PipeWire核心API#includestdio.h#includestdlib.hstructapp_data{structpw_loop*loop;// 应用创建的底层Loopstructpw_thread_loop*thread_loop;// Thread Loop管理对象};intmain(intargc,char*argv[]){structapp_datadata{0};intresult;pw_init(argc,argv);// 初始化PipeWire环境data.looppw_loop_new(NULL);// 创建底层pw_loopif(!data.loop){fprintf(stderr,pw_loop_new failed\n);pw_deinit();returnEXIT_FAILURE;}data.thread_looppw_thread_loop_new_full(data.loop,pipewire-worker,NULL);// 使用已有pw_loop创建Thread Loopif(!data.thread_loop){fprintf(stderr,pw_thread_loop_new_full failed\n);pw_loop_destroy(data.loop);pw_deinit();returnEXIT_FAILURE;}resultpw_thread_loop_start(data.thread_loop);// 启动独立事件线程if(result0){fprintf(stderr,pw_thread_loop_start failed: %d\n,result);pw_thread_loop_destroy(data.thread_loop);pw_loop_destroy(data.loop);pw_deinit();returnEXIT_FAILURE;}pw_thread_loop_lock(data.thread_loop);// 获取Loop互斥锁/* * 在临界区内可以安全执行 * * pw_context_new() * pw_context_connect() * pw_stream_new() * pw_stream_connect() */pw_thread_loop_unlock(data.thread_loop);// 释放Loop互斥锁pw_thread_loop_stop(data.thread_loop);// 停止工作线程pw_thread_loop_destroy(data.thread_loop);// 销毁Thread Loop封装对象pw_loop_destroy(data.loop);// 销毁应用创建的底层pw_looppw_deinit();// 释放PipeWire资源returnEXIT_SUCCESS;}5. 一句话总结pw_thread_loop_new_full()本质上是“使用指定的pw_loop、线程名称和属性创建一个能够在独立线程中运行该 Loop 的pw_thread_loop对象”。它负责完成底层 Loop 封装、Thread Loop 对象分配、名称设置和运行环境初始化但不会立即启动线程是自定义 PipeWire Loop、Core 异步通信、Stream 管理和多线程事件处理中的基础创建接口。