)
简介CSDN博客专家、《Android系统多媒体进阶实战》作者博主新书推荐《Android系统多媒体进阶实战》Android Audio工程师专栏地址Audio工程师进阶系列【原创干货持续更新中……】Android多媒体专栏地址多媒体系统工程师系列【原创干货持续更新中……】专题一 二AAOS车载系统AOSP14系统攻城狮入门视频实战课专题三Android14 Binder之HIDL与AIDL通信实战课专题四Android15快速自定义与集成音效实战课专题五Android15音频策略实战课专题六Android15音频性能实战课(无声/杂音/断音/爆音实战案例)人生格言人生从来没有捷径只有行动才是治疗恐惧和懒惰的唯一良药.更多原创,欢迎关注Android系统攻城狮文章目录1.前言要点概括2.应用场景与用法函数原型参数说明返回值应用场景3.调用流程剖析3.1核心步骤3.2调用流程图3.3生命周期图4.实战应用案例5.一句话总结1.前言本篇目的Linux PipeWire深度解析之pw_thread_loop_start调用流程与实战。要点概括核心功能启动PipeWire Thread Loop让内部pw_loop在独立后台线程中运行。工作机制创建并启动后台线程后台线程进入事件循环后负责处理PipeWire客户端侧的事件、IO、回调和异步通知。典型用途客户端不希望主线程阻塞时把PipeWire事件调度放到独立线程中运行。pw_thread_loop_start的本质是“启动事件循环线程”不是“启动音频播放”也不是“启动PipeWireGraph”。它只让Thread Loop内部的pw_loop开始调度事件。它和pw_thread_loop_new不同。pw_thread_loop_new只创建Thread Loop对象不会启动线程。它和pw_thread_loop_get_loop也不同get_loop只返回内部pw_loop用于创建Context、Stream或其他事件源。它和pw_thread_loop_stop是一对接口start负责启动后台线程stop负责停止并回收后台线程。它也不同于pw_main_loop_run。pw_main_loop_run通常会阻塞当前线程而pw_thread_loop_start会把事件循环放到后台线程运行使应用主线程可以继续执行自己的业务逻辑。2.应用场景与用法pw_thread_loop_start是PipeWire Thread Loop API中用于启动独立事件循环线程的接口。它位于PipeWire客户端运行环境的线程调度层。应用创建Thread Loop后可以通过pw_thread_loop_get_loop取得内部pw_loop再基于这个loop创建Context、Core、Stream或其他事件源。完成必要对象创建后调用pw_thread_loop_start启动后台线程让PipeWire客户端事件开始被调度。pw_thread_loop_start用于启动Thread Loop内部的事件循环线程。函数原型intpw_thread_loop_start(structpw_thread_loop*loop);参数说明structpw_thread_loop*loop;loop表示已经创建好的PipeWire Thread Loop对象。该对象通常由pw_thread_loop_new创建。调用pw_thread_loop_start之前应用应保证loop有效并且不要在销毁后的loop上再次调用start。对于需要跨线程访问的PipeWire对象应用应配合pw_thread_loop_lock、pw_thread_loop_unlock、pw_thread_loop_wait和pw_thread_loop_signal进行同步。返回值成功时返回0表示后台事件循环线程已经启动。失败时返回负错误码表示线程创建失败、状态异常或底层启动过程失败。工程代码中应检查返回值失败时释放已经创建的Context、Core、Stream和Thread Loop对象。应用场景第一类场景是PipeWire客户端需要非阻塞运行。如果应用使用pw_main_loop_run当前线程会进入事件循环并阻塞。对于播放器、录音程序、图形界面程序或嵌入式业务进程主线程通常还要处理UI、业务状态机、网络消息或控制命令这时更适合使用Thread Loop。第二类场景是Stream回调需要由独立线程调度。应用创建pw_stream后process、state_changed、param_changed等回调需要有事件循环驱动。pw_thread_loop_start启动后这些回调会随着内部pw_loop调度执行不需要应用主线程手动跑main loop。第三类场景是客户端需要同步等待异步结果。Thread Loop提供lock、wait、signal机制适合在主线程发起操作后等待后台PipeWire事件回调更新状态。例如等待Core连接完成、等待Stream进入目标状态、等待参数枚举完成等。第四类场景是复杂客户端需要统一管理PipeWire对象生命周期。在播放器、录音器、虚拟设备、音频路由工具和测试工具中Thread Loop可以作为PipeWire客户端对象的统一运行环境。Context、Core、Stream和Proxy都依赖这个Loop调度事件start之后这些对象才具备持续处理事件的基础。3.调用流程剖析3.1核心步骤1.应用调用pw_thread_loop_new创建Thread Loop对象。2.应用调用pw_thread_loop_get_loop取得内部pw_loop。3.应用基于内部pw_loop创建pw_context、pw_core、pw_stream或其他事件源。4.应用调用pw_thread_loop_start启动后台线程。5.Thread Loop创建线程并进入线程入口函数。6.后台线程进入内部pw_loop事件循环。7.后台线程发出启动完成信号使调用线程确认start过程完成。8.pw_thread_loop_start返回0应用主线程继续执行后续业务逻辑。9.后台线程持续调度PipeWire事件、IO事件、Stream回调和Proxy事件。10.应用退出时调用pw_thread_loop_stop停止后台线程再释放相关PipeWire对象。3.2调用流程图3.3生命周期图4.实战应用案例下面以“客户端使用独立Thread Loop连接PipeWire服务端”为例说明pw_thread_loop_start的实际用法。该案例目标是创建Thread Loop把PipeWire客户端事件调度放到后台线程中运行主线程不被PipeWire事件循环阻塞。structapp_data{structpw_thread_loop*loop;structpw_context*context;structpw_core*core;};staticintapp_init(structapp_data*data){intret;data-looppw_thread_loop_new(pipewire-client-loop,NULL);if(data-loopNULL)return-1;data-contextpw_context_new(pw_thread_loop_get_loop(data-loop),NULL,0);if(data-contextNULL)return-1;data-corepw_context_connect(data-context,NULL,0);if(data-coreNULL)return-1;retpw_thread_loop_start(data-loop);if(ret0)returnret;return0;}这段代码中pw_thread_loop_new只创建Thread Loop对象。pw_thread_loop_get_loop取得内部pw_loop后pw_context_new把Context绑定到这个Loop上。pw_context_connect创建Core连接对象。最后调用pw_thread_loop_start后台线程才开始运行PipeWire事件才会被持续调度。应用退出时需要按生命周期反向释放资源。staticvoidapp_destroy(structapp_data*data){if(data-loop!NULL)pw_thread_loop_stop(data-loop);if(data-core!NULL)pw_core_disconnect(data-core);if(data-context!NULL)pw_context_destroy(data-context);if(data-loop!NULL)pw_thread_loop_destroy(data-loop);}这个释放顺序的重点是先停止Thread Loop再释放绑定在该Loop上的PipeWire对象最后销毁Thread Loop本身。在复杂客户端中如果主线程和Thread Loop后台线程都可能访问同一批PipeWire对象应使用lock和unlock保护对象操作。staticvoidapp_safe_operation(structapp_data*data){pw_thread_loop_lock(data-loop);/* * 在这里执行需要和PipeWire回调互斥的对象操作。 * 例如修改Stream状态、读取共享状态、等待异步回调结果等。 */pw_thread_loop_unlock(data-loop);}如果主线程需要等待后台回调完成可以配合wait和signal使用。常见模式是主线程持锁后发起异步操作然后wait后台回调更新状态后signal主线程被唤醒后继续执行。pw_thread_loop_start本身不负责这些同步细节。它只负责把事件循环线程启动起来。真正的跨线程状态同步需要应用根据自己的对象生命周期和回调模型设计。工程中要特别注意三点。第一不要把pw_thread_loop_start当成Stream启动接口。Stream是否连接、是否进入PAUSED或STREAMING状态取决于pw_stream_connect、参数协商和服务端Graph调度。第二不要在Thread Loop回调中执行长时间阻塞操作。回调线程被阻塞后PipeWire客户端事件也会被阻塞可能导致状态更新延迟、Buffer处理不及时或连接超时。第三不要在销毁Thread Loop后继续使用内部pw_loop创建的对象。Context、Core、Stream和Proxy都依赖Loop调度事件生命周期必须和Thread Loop保持一致。5.一句话总结pw_thread_loop_start是PipeWire客户端侧的Thread Loop启动接口它启动后台事件循环线程让Context、Core、Stream和事件源具备持续调度能力但它不负责启动媒体流也不直接参与Buffer处理。
Linux PipeWire深度解析之pw_thread_loop_start调用流程与实战(八十六)
简介CSDN博客专家、《Android系统多媒体进阶实战》作者博主新书推荐《Android系统多媒体进阶实战》Android Audio工程师专栏地址Audio工程师进阶系列【原创干货持续更新中……】Android多媒体专栏地址多媒体系统工程师系列【原创干货持续更新中……】专题一 二AAOS车载系统AOSP14系统攻城狮入门视频实战课专题三Android14 Binder之HIDL与AIDL通信实战课专题四Android15快速自定义与集成音效实战课专题五Android15音频策略实战课专题六Android15音频性能实战课(无声/杂音/断音/爆音实战案例)人生格言人生从来没有捷径只有行动才是治疗恐惧和懒惰的唯一良药.更多原创,欢迎关注Android系统攻城狮文章目录1.前言要点概括2.应用场景与用法函数原型参数说明返回值应用场景3.调用流程剖析3.1核心步骤3.2调用流程图3.3生命周期图4.实战应用案例5.一句话总结1.前言本篇目的Linux PipeWire深度解析之pw_thread_loop_start调用流程与实战。要点概括核心功能启动PipeWire Thread Loop让内部pw_loop在独立后台线程中运行。工作机制创建并启动后台线程后台线程进入事件循环后负责处理PipeWire客户端侧的事件、IO、回调和异步通知。典型用途客户端不希望主线程阻塞时把PipeWire事件调度放到独立线程中运行。pw_thread_loop_start的本质是“启动事件循环线程”不是“启动音频播放”也不是“启动PipeWireGraph”。它只让Thread Loop内部的pw_loop开始调度事件。它和pw_thread_loop_new不同。pw_thread_loop_new只创建Thread Loop对象不会启动线程。它和pw_thread_loop_get_loop也不同get_loop只返回内部pw_loop用于创建Context、Stream或其他事件源。它和pw_thread_loop_stop是一对接口start负责启动后台线程stop负责停止并回收后台线程。它也不同于pw_main_loop_run。pw_main_loop_run通常会阻塞当前线程而pw_thread_loop_start会把事件循环放到后台线程运行使应用主线程可以继续执行自己的业务逻辑。2.应用场景与用法pw_thread_loop_start是PipeWire Thread Loop API中用于启动独立事件循环线程的接口。它位于PipeWire客户端运行环境的线程调度层。应用创建Thread Loop后可以通过pw_thread_loop_get_loop取得内部pw_loop再基于这个loop创建Context、Core、Stream或其他事件源。完成必要对象创建后调用pw_thread_loop_start启动后台线程让PipeWire客户端事件开始被调度。pw_thread_loop_start用于启动Thread Loop内部的事件循环线程。函数原型intpw_thread_loop_start(structpw_thread_loop*loop);参数说明structpw_thread_loop*loop;loop表示已经创建好的PipeWire Thread Loop对象。该对象通常由pw_thread_loop_new创建。调用pw_thread_loop_start之前应用应保证loop有效并且不要在销毁后的loop上再次调用start。对于需要跨线程访问的PipeWire对象应用应配合pw_thread_loop_lock、pw_thread_loop_unlock、pw_thread_loop_wait和pw_thread_loop_signal进行同步。返回值成功时返回0表示后台事件循环线程已经启动。失败时返回负错误码表示线程创建失败、状态异常或底层启动过程失败。工程代码中应检查返回值失败时释放已经创建的Context、Core、Stream和Thread Loop对象。应用场景第一类场景是PipeWire客户端需要非阻塞运行。如果应用使用pw_main_loop_run当前线程会进入事件循环并阻塞。对于播放器、录音程序、图形界面程序或嵌入式业务进程主线程通常还要处理UI、业务状态机、网络消息或控制命令这时更适合使用Thread Loop。第二类场景是Stream回调需要由独立线程调度。应用创建pw_stream后process、state_changed、param_changed等回调需要有事件循环驱动。pw_thread_loop_start启动后这些回调会随着内部pw_loop调度执行不需要应用主线程手动跑main loop。第三类场景是客户端需要同步等待异步结果。Thread Loop提供lock、wait、signal机制适合在主线程发起操作后等待后台PipeWire事件回调更新状态。例如等待Core连接完成、等待Stream进入目标状态、等待参数枚举完成等。第四类场景是复杂客户端需要统一管理PipeWire对象生命周期。在播放器、录音器、虚拟设备、音频路由工具和测试工具中Thread Loop可以作为PipeWire客户端对象的统一运行环境。Context、Core、Stream和Proxy都依赖这个Loop调度事件start之后这些对象才具备持续处理事件的基础。3.调用流程剖析3.1核心步骤1.应用调用pw_thread_loop_new创建Thread Loop对象。2.应用调用pw_thread_loop_get_loop取得内部pw_loop。3.应用基于内部pw_loop创建pw_context、pw_core、pw_stream或其他事件源。4.应用调用pw_thread_loop_start启动后台线程。5.Thread Loop创建线程并进入线程入口函数。6.后台线程进入内部pw_loop事件循环。7.后台线程发出启动完成信号使调用线程确认start过程完成。8.pw_thread_loop_start返回0应用主线程继续执行后续业务逻辑。9.后台线程持续调度PipeWire事件、IO事件、Stream回调和Proxy事件。10.应用退出时调用pw_thread_loop_stop停止后台线程再释放相关PipeWire对象。3.2调用流程图3.3生命周期图4.实战应用案例下面以“客户端使用独立Thread Loop连接PipeWire服务端”为例说明pw_thread_loop_start的实际用法。该案例目标是创建Thread Loop把PipeWire客户端事件调度放到后台线程中运行主线程不被PipeWire事件循环阻塞。structapp_data{structpw_thread_loop*loop;structpw_context*context;structpw_core*core;};staticintapp_init(structapp_data*data){intret;data-looppw_thread_loop_new(pipewire-client-loop,NULL);if(data-loopNULL)return-1;data-contextpw_context_new(pw_thread_loop_get_loop(data-loop),NULL,0);if(data-contextNULL)return-1;data-corepw_context_connect(data-context,NULL,0);if(data-coreNULL)return-1;retpw_thread_loop_start(data-loop);if(ret0)returnret;return0;}这段代码中pw_thread_loop_new只创建Thread Loop对象。pw_thread_loop_get_loop取得内部pw_loop后pw_context_new把Context绑定到这个Loop上。pw_context_connect创建Core连接对象。最后调用pw_thread_loop_start后台线程才开始运行PipeWire事件才会被持续调度。应用退出时需要按生命周期反向释放资源。staticvoidapp_destroy(structapp_data*data){if(data-loop!NULL)pw_thread_loop_stop(data-loop);if(data-core!NULL)pw_core_disconnect(data-core);if(data-context!NULL)pw_context_destroy(data-context);if(data-loop!NULL)pw_thread_loop_destroy(data-loop);}这个释放顺序的重点是先停止Thread Loop再释放绑定在该Loop上的PipeWire对象最后销毁Thread Loop本身。在复杂客户端中如果主线程和Thread Loop后台线程都可能访问同一批PipeWire对象应使用lock和unlock保护对象操作。staticvoidapp_safe_operation(structapp_data*data){pw_thread_loop_lock(data-loop);/* * 在这里执行需要和PipeWire回调互斥的对象操作。 * 例如修改Stream状态、读取共享状态、等待异步回调结果等。 */pw_thread_loop_unlock(data-loop);}如果主线程需要等待后台回调完成可以配合wait和signal使用。常见模式是主线程持锁后发起异步操作然后wait后台回调更新状态后signal主线程被唤醒后继续执行。pw_thread_loop_start本身不负责这些同步细节。它只负责把事件循环线程启动起来。真正的跨线程状态同步需要应用根据自己的对象生命周期和回调模型设计。工程中要特别注意三点。第一不要把pw_thread_loop_start当成Stream启动接口。Stream是否连接、是否进入PAUSED或STREAMING状态取决于pw_stream_connect、参数协商和服务端Graph调度。第二不要在Thread Loop回调中执行长时间阻塞操作。回调线程被阻塞后PipeWire客户端事件也会被阻塞可能导致状态更新延迟、Buffer处理不及时或连接超时。第三不要在销毁Thread Loop后继续使用内部pw_loop创建的对象。Context、Core、Stream和Proxy都依赖Loop调度事件生命周期必须和Thread Loop保持一致。5.一句话总结pw_thread_loop_start是PipeWire客户端侧的Thread Loop启动接口它启动后台事件循环线程让Context、Core、Stream和事件源具备持续调度能力但它不负责启动媒体流也不直接参与Buffer处理。