并发编程高性能计算【免费下载链接】oneTBBoneAPI Threading Building Blocks (oneTBB)项目地址https://gitcode.com/gh_mirrors/on/oneTBB点击查看免费下载this_task_arena是 oneTBB 提供的一个命名空间用于让调用线程与当前正在使用的 task_arena任务竞技场进行交互包含查询当前线程在竞技场中的索引、查询竞技场并发度、以隔离方式执行函数、向竞技场异步投递任务等全局函数。本文以 this_task_arena_ns.rst 为骨架结合 task_arena.h 头文件实现、arena.cpp 运行时实现与测试用例系统讲解该命名空间的每个 API 的语义、注意事项与底层原理帮助你准确地在自己的并行程序中使用当前竞技场的能力。背景什么是当前 task_arena在 oneTBB 中task_arena详见 task_arena_cls.rst代表一个显式的、由用户管理的任务调度竞技场线程在其中共享并执行任务竞技场的并发度concurrency level限制了可同时执行任务的线程数量。每个用户线程如果在显式task_arena之外调用任何并行构造都会使用与该调用线程关联的隐式竞技场implicit task arena表示对象。this_task_arena命名空间正是为调用线程当前所在的竞技场这一概念提供全局函数入口——无论该竞技场是显式创建并通过execute加入的还是线程默认关联的隐式竞技场都能通过本命名空间的函数统一操作。从实现上看这些函数在 task_arena.h 中通过using声明汇集了detail::d1命名空间中的内部实现并以nullptr作为当前竞技场的标记传给运行时namespace this_task_arena { using detail::d1::current_thread_index; using detail::d1::max_concurrency; using detail::d1::isolate; using detail::d1::enqueue; using detail::d1::start_parallel_phase; using detail::d1::end_parallel_phase; } // namespace this_task_arenaAPI 总览this_task_arena定义在头文件oneapi/tbb/task_arena.h中完整接口如下与 this_task_arena_ns.rst 中的声明一致namespace oneapi { namespace tbb { namespace this_task_arena { int current_thread_index(); int max_concurrency(); templatetypename F auto isolate(F f) - decltype(f()); templatetypename F void enqueue(F f); templatetypename F void enqueue(F f, task_group tg); void enqueue(task_handle h); // Preview feature: parallel_phase Interface void start_parallel_phase(); void end_parallel_phase(bool with_fast_leave false); } // namespace this_task_arena } // namespace tbb } // namespace oneapi从功能上可分为四组查询函数current_thread_index()、max_concurrency()用于获知当前线程与竞技场的运行时状态隔离执行isolate()将一段代码限制为只处理其自身范围内调度的任务异步投递三个enqueue()重载向当前竞技场投递任务后立即返回预览特性start_parallel_phase()/end_parallel_phase()向调度器提示并行区域的起止需宏TBB_PREVIEW_PARALLEL_PHASE开启。查询当前线程的竞技场索引current_thread_index()int current_thread_index();该函数返回调用线程在当前task_arena中的线程索引thread index。线程索引是一个介于0 与竞技场并发度之间的整数如果调用线程尚未初始化任务调度器则返回task_arena::not_initialized其值为-2见 task_arena.h。语义要点索引在应用线程application thread和工作者线程worker thread加入竞技场时分配直到退出竞技场时保持同一竞技场内的线程索引唯一——同一时刻竞技场中不会有两个线程持有相同索引但索引不保证连续例如线程退出后空出的槽位可能不立即复用底层实现通过r1::execution_slot(nullptr)查询当前线程的槽位号若返回slot_id(-1)则映射为not_initialized见 task_arena.h。三个重要注意事项索引可能在任务之间变化由于线程若未执行任务可随时退出竞技场即使属于同一 task_group 或同一算法的两个任务之间线程索引也可能改变不同竞技场的索引可相同使用不同竞技场的线程可能持有相同的索引值因此索引只在同一竞技场内部具有唯一性语义嵌套竞技场会临时改变索引在execute()中加入嵌套竞技场时当前索引值会改变但外层竞技场的索引会在返回时恢复。典型用法与测试佐证current_thread_index()常用于并行分区、负载均衡或调试时识别执行线程。例如在 test_arena_constraints.cpp 中测试通过它验证嵌套竞技场的行为if (tbb::this_task_arena::current_thread_index() 0) { // ... } REQUIRE_MESSAGE(tbb::this_task_arena::max_concurrency() 1, Nested arena should have 1 slot.);在 test_partitioner.cpp 中partitioner 测试使用current_thread_index()记录每个执行线程的槽位int thread_id tbb::this_task_arena::current_thread_index();查询当前竞技场的并发度max_concurrency()int max_concurrency();返回调用线程当前task_arena的并发度concurrency level即竞技场内可同时参与任务处理的线程数上限。如果调用线程尚未初始化任务调度器则返回根据硬件配置自动确定的并发度——从实现看它直接委托给r1::max_concurrency(nullptr)见 task_arena.h。与task_arena::max_concurrency()的差异类方法task_arena::max_concurrency()返回的是该task_arena对象无论是否初始化配置的并发度而this_task_arena::max_concurrency()是当前竞技场的并发度适用于不持有竞技场对象句柄、或只想了解当前执行环境的场景。两者底层最终都汇聚到运行时层对竞技场槽位数量的查询逻辑。使用场景在并行算法内部获取当前竞技场的线程数用于自适应分块在进入显式竞技场之前查询系统默认并发度此时等价于硬件并发度测试中验证嵌套竞技场并发度被正确约束如 test_flow_graph.cpp 断言max_concurrency() 1。隔离执行isolate()templatetypename F auto isolate(F f) - decltype(f());在隔离区域isolation region中运行指定的函数对象functor调用线程被限制为只处理该函数作用域内调度的任务并返回函数对象的返回值。F类型必须满足 ISO C 标准 [function.objects] 一节描述的 Function Objects 要求。核心语义isolate的典型用途是串行化关键区段当多个线程在同一个竞技场中并行执行时如果某段代码不希望与其他线程的任务发生交叉例如必须独占某些资源或保证执行顺序可用isolate包裹从实现看isolate最终调用r1::isolate_within_arena(func, /*isolation*/ 0)见 task_arena.h把函数对象包装为task_arena_function委托后送入运行时执行运行时保证在隔离区域内调度器不会把其他隔离区外任务派给该线程执行。一个重要告诫函数对象返回的对象不能是引用类型。如果需要返回引用语义的结果请改用std::reference_wrapper包装。测试佐证test_flow_graph_priorities.cpp 展示了isolate与流图配合的用法tbb::this_task_arena::isolate( IsolationFunctor(work_size) );异步投递任务三个enqueue()重载this_task_arena提供三种向当前竞技场投递任务的重载形式投递后立即返回任务由竞技场中的工作者线程或额外的专用工作者线程在合适时机执行。形式一投递函数对象templatetypename F void enqueue(F f);将处理指定函数对象的任务投入调用线程当前使用的task_arena然后立即返回。F必须满足 Function Objects 要求。其行为与对task_arena对象应用enqueue(F f)等价只不过该task_arena是以attach参数构造即连接到当前竞技场的。形式二投递到指定 task_grouptemplatetypename F void enqueue(F f, task_group tg);将处理函数对象的任务加入tg并投递到调用线程当前使用的task_arena中。其行为严格等价于this_task_arena::enqueue( tg.defer(std::forwardF(f)) );也就是说tg.defer()先把函数对象封装成可延迟执行的任务再通过enqueue(task_handle)重载入队。借助 task_group调用方后续可以用tg.wait()等待该任务完成。形式三投递 task_handlevoid enqueue(task_handle h);将h拥有的任务投递到调用线程当前使用的task_arena。行为与通用版本templatetypename F void enqueue(F f)等价只是参数类型不同。注意h不能为空empty否则会导致未定义行为undefined behavior。实现中对应的断言位于 task_arena.h__TBB_ASSERT(th ! nullptr, Attempt to schedule empty task_handle);。底层实现三个重载最终都汇入内部函数enqueue_impl(F f, task_arena_base* ta)见 task_arena.h其中ta传nullptr表示当前竞技场templatetypename F void enqueue_impl(F f, task_arena_base* ta) { small_object_allocator alloc{}; r1::enqueue(*alloc.new_objectenqueue_tasktypename std::decayF::type(std::forwardF(f), alloc), ta); }enqueue_tasktask_arena.h继承自task在execute中调用函数对象并自行释放内存。值得注意的是入队任务采用small_object_allocator小对象池分配器管理生命周期这也是 oneTBB 降低动态分配开销的惯用手法。与task_arena::enqueue()的行为对照类方法task_arena::enqueue()的语义见 task_arena_cls.rst对本命名空间同样适用要点如下投递不要求调用线程加入竞技场——任意数量的外部线程都可以无阻塞地向竞技场提交工作即使总工作者线程数为零也会创建一个额外的专用工作者线程来执行入队任务保证任务最终会被执行不保证入队任务与竞技场中其他任务并发执行函数对象中抛出且未捕获的异常会导致未定义行为。预览特性parallel_phase接口this_task_arena的预览特性parallel_phase接口start_parallel_phase()/end_parallel_phase()用于向调度器提示并行区域的起止从而影响工作者线程的驻留策略。完整的接口说明参见 parallel_phase.rst。启用方式这是一个预览特性preview feature需要定义宏#define TBB_PREVIEW_PARALLEL_PHASE 1启用后特性测试宏TBB_HAS_PARALLEL_PHASE会被定义。注意预览特性可能在未来版本中发生不兼容变更。设计动机默认情况下oneTBB 采用延迟线程退出delayed thread leave启发式工作者线程完成竞技场中的工作后会保留一段由实现定义的时长预期很快会有新的并行任务到来从而降低后续并行计算的启动延迟。这对大多数负载是有益的但在以下场景可能适得其反并行任务以不规则的间隔提交、或存在长间隙空闲线程浪费 CPU 资源oneTBB 与其他线程库交错使用空闲线程造成 CPU 过度订阅oversubscription。parallel_phase接口让用户在周期性的并行工作区域前后打上标记区域内调度器更积极地保留线程区域结束后及时释放线程。API 语义void this_task_arena::start_parallel_phase(); void this_task_arena::end_parallel_phase(bool with_fast_leave false);start_parallel_phase()标记当前竞技场中并行阶段的开始作为调度器保留线程的提示同时也可作为预热提示允许调度器提前唤醒工作者线程end_parallel_phase(bool with_fast_leave false)标记并行阶段结束调度器不再保留线程若with_fast_leave为true工作者线程的离开策略会被临时设置为fast。对应用层更友好的 RAII 形式是task_arena::scoped_parallel_phase文档中记为parallel_phase构造时开始并行阶段、析构时结束天然适配作用域详见下文示例。源码级状态机this_task_arena::start_parallel_phase/end_parallel_phase在 task_arena.h 中以nullptr为竞技场参数委托运行时inline void start_parallel_phase(task_arena::parallel_phase::flags f {}) { r1::enter_parallel_phase(nullptr, static_caststd::uintptr_t(f.my_start_flags)); } inline void end_parallel_phase(task_arena::parallel_phase::flags f {}) { r1::exit_parallel_phase(nullptr, static_caststd::uintptr_t(f.my_end_flags)); }运行时层arena.cpp将调用转发给竞技场内的线程离开管理器void task_arena_impl::enter_parallel_phase(d1::task_arena_base* ta, std::uintptr_t) { arena* a ...; // 解析当前竞技场 a-my_thread_leave.register_parallel_phase(); } void task_arena_impl::exit_parallel_phase(d1::task_arena_base* ta, std::uintptr_t flags) { arena* a ...; a-my_thread_leave.unregister_parallel_phase(flags); }thread_leave_managerarena.h用一个无锁状态字维护离开策略状态机包含四种状态位static const std::uintptr_t DELAYED_LEAVE 0; // 延迟离开默认启发式 static const std::uintptr_t FAST_LEAVE 1; // 快速离开 static const std::uintptr_t ONE_TIME_FAST_LEAVE 1 1; // 一次性快速离开 static const std::uintptr_t PARALLEL_PHASE 1 2; // 处于并行阶段register_parallel_phase()通过原子fetch_add(PARALLEL_PHASE)增加并行阶段计数支持嵌套并行阶段并清除可能存在的一次性快速离开状态unregister_parallel_phase(flags)则递减计数若这是最后一个并行阶段且携带end_fast_leave标志则转入ONE_TIME_FAST_LEAVE让线程在本次离开时采用快速策略见 arena.h。线程是否允许驻留由is_retention_allowed()判定状态为FAST_LEAVE或ONE_TIME_FAST_LEAVE时不允许驻留。这套状态机正是文档中保留策略语义的底层实现。离开策略leave_policy与 global_control 集成task_arena::leave_policy枚举automatic/fast可在构造或initialize竞技场时设置而global_control::leave_policy参数见 global_control.h 与 parallel_phase.rst提供应用级的默认控制。两者在竞技场创建时的组合规则如下竞技场leave_policy全局leave_policy初始状态fast任意快速离开automaticfast快速离开automaticautomatic默认系统特定策略要点多个global_control对象并存时只要任一存活对象的leave_policy为fast全局生效值即为fast已初始化的竞技场含隐式竞技场不受global_control::leave_policy后续变更影响全局控制提供应用级默认task_arena::leave_policy与parallel_phase提供竞技场级控制竞技场初始化后parallel_phaseAPI 可在运行时动态调整线程离开行为。完整示例来自 parallel_phase_example.cpp 的官方示例展示了global_controlscoped_parallel_phase的搭配用法#define TBB_PREVIEW_PARALLEL_PHASE 1 #include oneapi/tbb/global_control.h #include oneapi/tbb/task_arena.h #include oneapi/tbb/parallel_for.h #include oneapi/tbb/parallel_sort.h #include vector int main() { oneapi::tbb::global_control gc( oneapi::tbb::global_control::leave_policy, oneapi::tbb::task_arena::leave_policy::fast ); oneapi::tbb::task_arena ta; std::vectorint data(1000); { oneapi::tbb::task_arena::parallel_phase phase{ta}; ta.execute([data]() { oneapi::tbb::parallel_for(std::size_t(0), data.size(), data { data[i] static_castint(i*i); }); }); for (std::size_t i 1; i data.size(); i) { data[i] data[i-1]; } ta.execute([data]() { oneapi::tbb::parallel_sort(data.begin(), data.end()); }); } }该例中global_control::leave_policy被设为task_arena::leave_policy::fast使得以automatic初始化的竞技场默认采用快速离开——并行工作一结束工作者线程预期不再驻留。但工作流包含两段并行工作初始化数据、排序被串行工作前缀和隔开的模式于是用scoped_parallel_phase即task_arena::parallel_phaseRAII 对象包裹整个区域向调度器提示后续还有并行工作从而让工作者线程在两段并行工作之间得以驻留避免频繁的线程唤醒/休眠开销。使用建议与注意事项汇总索引语义仅限同一竞技场内current_thread_index()返回的索引在竞技场内唯一但不保证连续且可能随线程退出/重入而变化跨竞技场比较索引没有意义。not_initialized的判定在调用任何并行构造之前查询索引会得到task_arena::not_initialized代码中应显式处理该分支。isolate的返回值不要从隔离函数中返回引用需要引用语义时用std::reference_wrapper。入队任务的异常enqueue的函数对象中未捕获的异常会导致未定义行为请务必在任务内自行捕获处理。空的task_handle投递task_handle前必须确认其非空。预览特性需显式开启parallel_phase接口依赖TBB_PREVIEW_PARALLEL_PHASE宏并受TBB_HAS_PARALLEL_PHASE特性测试宏约束生产环境使用前请评估 API 稳定性。深入阅读task_arena 类参考task_arena的构造、execute/enqueue/wait_for等完整成员函数语义parallel_phase 接口文档leave_policy枚举、scoped_parallel_phase与global_control::leave_policy的完整说明task_arena.hthis_task_arena命名空间声明与内部enqueue_impl、isolate_impl实现arena.cpp 与 arena.henter_parallel_phase/exit_parallel_phase运行时转发与thread_leave_manager状态机test_arena_constraints.cppcurrent_thread_index/max_concurrency在嵌套竞技场场景下的测试佐证。赞分享并发编程高性能计算【免费下载链接】oneTBBoneAPI Threading Building Blocks (oneTBB)项目地址https://gitcode.com/gh_mirrors/on/oneTBB点击查看免费下载相关推荐oneTBB task_arena::attach 详解用 attach 标签复用当前线程的任务竞技场oneTBB task_arena::attach 详解用 attach 标签复用当前线程的任务竞技场 本文是一份面向 oneAPI Threading Bu并发编程高性能计算深入解析 oneTBB this_task_arena 命名空间线程索引、并发度查询与隔离/入队调度原语深入解析 oneTBB this_task_arena 命名空间线程索引、并发度查询与隔离/入队调度原语 this_task_arena 是 oneTBB当开发工具构建工具系统编程oneTBB Task Scheduler Bypass 深入解析让下一个任务直接在当前线程执行oneTBB Task Scheduler Bypass 深入解析让下一个任务直接在当前线程执行 导读 Task Scheduler Bypass任务调度旁开发工具构建工具系统编程上一篇jevgrep 认证配置完整指南jg auth 连接 Vercel、TypeSafe 等 4 大 Provider 全步骤下一篇PRINTFILM部署进阶指南从Docker一键启动到源码构建与生产运维避坑清单创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考