Taskflow:子流任务(Subflow Tasking)

创建Subflow

DAG任务中,有一种常见的场景,一个任务可能在执行期间产生新的任务,然后紧接着执行新任务。 之前提到的静态图就没有办法实现这样一个功能了,所以Taskflow提供了另一种流的节点:Subflow,Subflow的API与Taskflow无异,但又可以作为Taskflow的一个节点。

比如描述如下依赖图:
在这里插入图片描述

#include <memory>
#include <taskflow/taskflow.hpp>
int main() {tf::Executor executor; tf::Taskflow taskflow;tf::Task A = taskflow.emplace([] () {}).name("A");  // static task Atf::Task C = taskflow.emplace([] () {}).name("C");  // static task Ctf::Task D = taskflow.emplace([] () {}).name("D");  // static task D// 通过lambda创建subflow// 开始执行的时候,会创建一个subflow,然后通过引用传给lambda// 只有当本subflow执行完成之后,才会执行taskflowtf::Task B = taskflow.emplace([] (tf::Subflow& subflow) { tf::Task B1 = subflow.emplace([] () {}).name("B1");  // subflow task B1tf::Task B2 = subflow.emplace([] () {}).name("B2");  // subflow task B2tf::Task B3 = subflow.emplace([] () {}).name("B3");  // subflow task B3B1.precede(B3);  // B1 runs bofore B3B2.precede(B3);  // B2 runs before B3}).name("B");A.precede(B);  // B runs after AA.precede(C);  // C runs after AB.precede(D);  // D runs after BC.precede(D);  // D runs after Ctaskflow.dump(std::cout);      // 在执行前,subflow无法展开,subflow只会显示节点Bexecutor.run(taskflow).get();  // execute the graph to spawn the subflowtaskflow.dump(std::cout);      // 执行完毕后,才可以完全展开return 0;
}

在run之前dump,subflow只会被当作普通节点:

在这里插入图片描述

在run之后调用,subflow被展开,得到真正的依赖图:
在这里插入图片描述

Join a Subflow

Subflow 在离开其上下文时默认调用join,表示需要把subflow中的task执行完,才完成subflow的执行。同时,还可以在上下文中显式调用join,来完成递归模式:

#include <memory>
#include <taskflow/taskflow.hpp>// 递归计算斐波那契数列
int spswm(int n, tf::Subflow& sbf) {if(n < 2) return n;int res1 = 0, res2 = 0;// 生成两个递归子任务.sbf.emplace([&res1, n](tf::Subflow& sbf_inner){res1 = spswm(n-1, sbf_inner);}).name("sub Task:_"+std::to_string(n-1));sbf.emplace([&res2, n](tf::Subflow& sbf_inner){res2 = spswm(n-2, sbf_inner);}).name("sub Task:_"+std::to_string(n-2));// 显式调用join,得到两个子任务的返回值sbf.join();return res1 + res2; 
}
int main() {tf::Executor executor; tf::Taskflow taskflow;int res = 0; // 用于存放最后的结果taskflow.emplace([&res](tf::Subflow& sbf){res = spswm(5, sbf); // 计算5的斐波那契数}).name("main Task");executor.run(taskflow).wait();std::cout << "5的斐波那契数:" << res << std::endl;taskflow.dump(std::cout);    return 0;
}

调用图如下:

在这里插入图片描述

Detach a Subflow

和线程一样,Subflow 可以Detach出去,单独执行(并最后被主Taskflow Join)

#include <taskflow/taskflow.hpp>int main() {tf::Executor executor; tf::Taskflow taskflow;tf::Task A = taskflow.emplace([] () {}).name("A");  // static task Atf::Task C = taskflow.emplace([] () {}).name("C");  // static task Ctf::Task D = taskflow.emplace([] () {}).name("D");  // static task Dtf::Task B = taskflow.emplace([] (tf::Subflow& subflow) { tf::Task B1 = subflow.emplace([] () {}).name("B1");  // static task B1tf::Task B2 = subflow.emplace([] () {}).name("B2");  // static task B2tf::Task B3 = subflow.emplace([] () {}).name("B3");  // static task B3B1.precede(B3);    // B1 runs bofore B3B2.precede(B3);    // B2 runs before B3subflow.detach();  // 分离出Taskflow,单独执行}).name("B");A.precede(B);  // B runs after AA.precede(C);  // C runs after AB.precede(D);  // D runs after BC.precede(D);  // D runs after Cexecutor.run(taskflow).wait();taskflow.dump(std::cout);    return 0;
}

最终结构如下:
在这里插入图片描述

detach出去的Subflow是临时的,所以,如果执行的是run_n, ABCD四个节点只会构造一次,但是subflow会被构造多次:

#include <taskflow/taskflow.hpp>int main() {tf::Executor executor; tf::Taskflow taskflow;tf::Task A = taskflow.emplace([] () {}).name("A");  // static task Atf::Task C = taskflow.emplace([] () {}).name("C");  // static task Ctf::Task D = taskflow.emplace([] () {}).name("D");  // static task Dtf::Task B = taskflow.emplace([] (tf::Subflow& subflow) { tf::Task B1 = subflow.emplace([] () {}).name("B1");  // static task B1tf::Task B2 = subflow.emplace([] () {}).name("B2");  // static task B2tf::Task B3 = subflow.emplace([] () {}).name("B3");  // static task B3B1.precede(B3);    // B1 runs bofore B3B2.precede(B3);    // B2 runs before B3subflow.detach();  // 分离出Taskflow,单独执行}).name("B");A.precede(B);  // B runs after AA.precede(C);  // C runs after AB.precede(D);  // D runs after BC.precede(D);  // D runs after Cexecutor.run_n(taskflow, 5).wait();assert(taskflow.num_tasks() == 19);taskflow.dump(std::cout);return 0;
}

在这里插入图片描述

嵌套子图

Subflow 支持递归,也支持嵌套:

#include <taskflow/taskflow.hpp>int main() {tf::Taskflow taskflow;tf::Task A = taskflow.emplace([] (tf::Subflow& sbf){std::cout << "A spawns A1 & subflow A2\n";tf::Task A1 = sbf.emplace([] () {std::cout << "subtask A1\n";}).name("A1");tf::Task A2 = sbf.emplace([] (tf::Subflow& sbf2){std::cout << "A2 spawns A2_1 & A2_2\n";tf::Task A2_1 = sbf2.emplace([] () {std::cout << "subtask A2_1\n";}).name("A2_1");tf::Task A2_2 = sbf2.emplace([] () {std::cout << "subtask A2_2\n";}).name("A2_2");A2_1.precede(A2_2);}).name("A2");A1.precede(A2);}).name("A");// execute the graph to spawn the subflowtf::Executor().run(taskflow).get();taskflow.dump(std::cout);
}

在这里插入图片描述

同样,也可以detach 子图的子图,独立执行,最终都会被master Taskflow 统一Join(类似进程与子进程的关系)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/781259.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

node.js学习(2)

版权声明 以下文章为尚硅谷PDF资料&#xff0c;B站视频链接&#xff1a;【尚硅谷Node.js零基础视频教程&#xff0c;nodejs新手到高手】仅供个人学习交流使用。如涉及侵权问题&#xff0c;请立即与本人联系&#xff0c;本人将积极配合删除相关内容。感谢理解和支持&#xff0c;…

AQS的基本原理

AQS&#xff08;AbstractQueuedSynchronizer&#xff09;是一个用于构建锁和同步器的框架&#xff0c;许多同步器都可以通过AQS很容易并且高效的构造出来。不仅Reentrant和Semaphore是基于AQS构建的&#xff0c;还包括CountDownLatch、ReentrantReadWriteLock、SynchronousQueu…

ttkbootstrap界面美化系列之Notebook(四)

在简单的界面设计中&#xff0c;Notebook也是常用的组件之一&#xff0c;Notebook组件的引入可以根据标签来切换不同的界面。使得界面更有层次感&#xff0c;不必都挤在一个界面上。在tkinter中就有Notebook组件&#xff0c;在ttkbootstrap中&#xff0c;同样也对Notebook进行了…

周末总结(2024/03/30)

工作 接受破烂现状&#xff0c;改变状态 上周一周的工作都感觉是摸鱼状态&#xff0c;每天只有三个小时左右的时间聚焦在工作上&#xff0c;其他时间都在胡思乱想。但是我发现可以在工作中学习和下班相关的技术栈。我无意改变自己的工作状态&#xff0c;只想在5月底找好下家然后…

应用侧渲染流程

应用侧渲染流程 《Android应用程序UI硬件加速渲染环境初始化过程分析》 https://blog.csdn.net/Luoshengyang/article/details/45769759 《Android HWUI绘制流程》 https://wizzie.top/android/android_HWUI_Draw/#1-gpu%E6%B8%B2%E6%9F%93%E7%A1%AC%E4%BB%B6%E5%8A%A0%E9%…

Linux+ARM 简单环境检测---软件部分

1、前言 这个是我学习linuxARM的在做的第一个软硬件结合项目&#xff0c;以往的类似这种整体类项目还是光单片机的时候&#xff0c;linux软件部分学习了差不多快一年了&#xff0c;因为各种事情耽搁&#xff0c;这个项目一直没有静下心来完成&#xff0c;不过终于哈哈哈哈搞完了…

代码随想录——移除元素(Leetcode27)

题目链接 暴力&#xff1a;&#xff08;没有改变元素相对位置&#xff09; class Solution {public int removeElement(int[] nums, int val) {int len nums.length;for(int i 0; i < len; i){if(nums[i] val){for(int j i 1; j < len; j){nums[j-1] nums[j];}i…

VS2019连接MySQL

VS2019连接MySQL 下载MySQL Connector/C配置头文件&#xff0c;库文件路径配置头文件路径配置库的路径复制dll文件 MySQL的用户设置将权限赋值给新用户 编写代码往数据库写入 老师布置的作业让我们用VS2019连接MySQL实现一个小型的日志系统&#xff0c;中间踩了很多的坑&#x…

chatui工具使用记录与比较

概述 cahtui相关工具可谓是层出不穷&#xff0c;方便了我们使用各个大模型。这里我把我知道的整理下列出来&#xff0c;顺便做一比较。 简单比较 openWebUI&#xff0c;star 11.1k&#xff0c;仿chatgpt风格&#xff0c;支持openapi、可以对接Ollama进行对话&#xff0c;功能…

Finetuned Language Models Are Zero-Shot Learners

Abstract 本文探索了一种简单的方法来提升语言模型的零样本(zero-shot)学习能力。我们发现 指令微调(instruction tuning) 显著提高了未见任务的零样本性能。 指令微调:即在一组通过指令描述的数据集上对模型进行微调我们对一个 137B 参数的预训练模型在 60 个 NLP 任务上…

springboot婚庆系统

摘 要 随着科学技术的飞速发展&#xff0c;各行各业都在努力与现代先进技术接轨&#xff0c;通过科技手段提高自身的优势&#xff1b;对于婚庆系统当然也不能排除在外&#xff0c;随着网络技术的不断成熟&#xff0c;带动了婚庆系统&#xff0c;它彻底改变了过去传统的管理方式…

【Gitea的介绍】

&#x1f525;博主&#xff1a;程序员不想YY啊&#x1f525; &#x1f4ab;CSDN优质创作者&#xff0c;CSDN实力新星&#xff0c;CSDN博客专家&#x1f4ab; &#x1f917;点赞&#x1f388;收藏⭐再看&#x1f4ab;养成习惯 &#x1f308;希望本文对您有所裨益&#xff0c;如有…

Matlab-R2022b-安装文件分享

​一、MATLAB主要特点和功能 MATLAB是一款强大的科学计算软件&#xff0c;专门用于算法开发、数据分析、数值计算以及科学数据可视化。 以下是一些MATLAB的主要特点和功能&#xff1a; 1.矩阵运算: MATLAB的名字来源于"Matrix Laboratory"&#xff08;矩阵实验室&…

在同一个网站上自动下载多个子页面内容

一、问题现象 第一次遇到这样的问题&#xff0c;如下图&#xff1a; 即在同一个网站上下载多个内容时&#xff0c;第一个内容明明已经正常get到了&#xff0c;但开始第二个页面的查询 以后&#xff0c;原来已经查出的内容就找不到了。 二、解决办法 我不知道大家是不是遇到…

常见的数据结构相关的面试问题

1.请解释什么是数据结构,以及它在计算机科学中的重要性。 数据结构定义:数据结构是一种组织数据的方式,它包括数据元素之间的关系以及对这些数据元素进行操作的规则。常见的数据结构包括数组、链表、栈、队列、树、图等。 数据结构的重要性: 提高算法效率:选择合适的数据结…

配置vsftpd服务

服务简介 1、FTP协议概览 FTP&#xff08;File Transfer Protocol&#xff09;⽂件传输协议&#xff0c;在TCP/IP协议族中属于应⽤层协议&#xff0c;是运⾏于 TCP协议之上是⼀种可靠的传输协议&#xff0c;主要功能⽤于实现⽤户间⽂件分发共享&#xff0c;以及⽹络管理 者在进…

Flutter开发之objectbox

Flutter开发之objectbox 在之前进行iOS开发的时候使用WCDB去进行管理数据库很方便&#xff0c;它支持ORM&#xff08;Object-Relational Mapping&#xff0c;对象关系映射&#xff09;&#xff0c;用于实现面向对象编程语言里不同类型系统的数据之间的转换。 那么在Flutter开发…

perl:字符串模糊匹配,计算 edit 距离

Levenshtein Distance&#xff0c;通常被称为编辑距离(Edit Distance)。该算法的概念是俄罗斯科学家弗拉基米尔莱文斯坦&#xff08;Levenshtein Vladimir&#xff09;于1965年提出。 它是用来计算两个字串之间&#xff0c;通过替换、插入、删除等操作将字符串str1转换成str2所…

作业练习(python)

第一题&#xff1a; cel eval(input()) fah 9 / 5 * cel 32 print("%.1f" % fah) 第二题&#xff1a; radius, length eval(input()) area radius * radius * 3.14159267 volume area * length print("%.2f" % area) print("%.2f" …

MNN介绍、安装与编译:移动端深度学习推理引擎

MNN介绍、安装与编译&#xff1a;移动端深度学习推理引擎 引言第一部分&#xff1a;MNN简介第二部分&#xff1a;MNN的安装第三部分&#xff1a;MNN的编译结语 引言 大家好&#xff0c;这里是程序猿代码之路。在移动设备上实现高效的深度学习模型推理一直是人工智能领域的一个挑…