CN111666146A - 多任务并发处理方法及装置 - Google Patents
多任务并发处理方法及装置 Download PDFInfo
- Publication number
- CN111666146A CN111666146A CN201910168719.9A CN201910168719A CN111666146A CN 111666146 A CN111666146 A CN 111666146A CN 201910168719 A CN201910168719 A CN 201910168719A CN 111666146 A CN111666146 A CN 111666146A
- Authority
- CN
- China
- Prior art keywords
- node
- processed
- nodes
- subtask
- task tree
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5061—Partitioning or combining of resources
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/50—Indexing scheme relating to G06F9/50
- G06F2209/5018—Thread allocation
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Mobile Radio Communication Systems (AREA)
Abstract
本发明公开了一种多任务并发处理方法及装置,该方法包括:确定任务树中的节点的服务状态及父节点;根据节点的所述服务状态及父节点确定所述节点是否为待处理节点;为待处理节点分配线程,以处理所述待处理节点对应的子任务。利用本发明方案,在提高任务处理效率的同时,可以有效避免线程资源的浪费。
Description
技术领域
本发明涉及任务管理领域,具体涉及一种多任务并发处理方法及装置。
背景技术
线程是程序中一个单一的顺序控制流程,在单个程序中同时运行多个线程完成不同的工作,称为多线程。多线程技术通过对多任务的并发执行可以提高整体执行效率。在任务之间存在依赖的情况下,比如任务a需要在任务b完成后才能执行,需要对线程之间的依赖进行管理,目前业内的基本管理方案为CountDownLatch机制(java技术的多线程协同机制),CountDownLatch是java的一个同步工具类,它允许一个或多个线程一直等待,直到其他线程执行完后再执行。
如图1中所示,存在依赖关系的多个子任务如下:子任务b需要等子任务a执行完毕后才能执行,子任务c需要等子任务a、b执行完毕后才能执行,子任务e需要等子任务c、d执行完毕后才能执行。采用多线程技术实现上述任务时,利用CountDownLatch机制来协调这些线程之间的同步。在时刻t1,多线程启动所有任务;在时刻t2,线程2、线程3、线程5阻塞,等待相应子任务完成。由于总线程资源有限,线程阻塞使得相应线程占用后不能再被分配,从而造成资源浪费。
发明内容
本发明实施例提供一种多任务并发处理方法及装置,避免对线程资源造成浪费。
为此,本发明提供如下技术方案:
一种多任务并发处理方法,所述方法包括:
确定任务树中的节点的服务状态及父节点;
根据节点的所述服务状态及父节点确定所述节点是否为待处理节点;
为待处理节点分配线程,以处理所述待处理节点对应的子任务。
可选地,所述确定任务树中的节点的服务状态包括:
将任务树中节点的初始服务状态设置为等待状态。
可选地,所述确定任务树中的节点的父节点包括:
根据任务树中节点间的依赖关系确定节点对应的父节点。
可选地,所述根据节点的所述服务状态及父节点确定所述节点是否为待处理节点包括:
判断节点的父节点是否为空并且服务状态是否为等待状态;
如果是,则确定所述节点为待处理节点。
可选地,所述为所述待处理节点分配线程,以处理所述待处理节点对应的子任务包括:
如果所述待处理节点有多个,则启用多线程以并行处理所述待处理节点对应的子任务。
可选地,所述方法还包括:
为所述待处理节点分配线程后,将所述待处理节点的服务状态设置为执行状态;
在所述子任务处理完成后,将所述子任务对应的节点的服务状态设置为完成状态。
可选地,在所述子任务处理完成后,所述方法还包括:
将所述任务树中父节点中包含所述处理完成的子任务对应的节点移除。
一种多任务并发处理装置,所述装置包括:
初始化模块,用于确定任务树中的节点的服务状态及父节点;
待处理节点确定模块,用于根据节点的所述服务状态及父节点确定所述节点是否为待处理节点;
线程管理模块,用于为待处理节点分配线程,以处理所述待处理节点对应的子任务。
可选地,所述初始化模块将任务树中节点的初始服务状态设置为等待状态。
可选地,所述初始化模块根据任务树中节点间的依赖关系确定节点对应的父节点。
可选地,所述待处理节点确定模块,具体用于判断节点的父节点是否为空并且服务状态是否为等待状态;如果是,则确定所述节点为待处理节点。
可选地,所述线程管理模块在所述待处理节点有多个时,启动多线程以并行处理所述待处理节点对应的子任务。
可选地,所述装置还包括:节点维护模块,用于在所述待处理节点分配线程后,将所述待处理节点的服务状态设置为执行状态;在所述子任务处理完成后,将所述子任务对应的节点的服务状态设置为完成状态。
可选地,所述节点维护模块,还用于在所述子任务处理完成后,将所述任务树中父节点中包含所述处理完成的子任务对应的节点移除。
一种电子设备,包括:一个或多个处理器、存储器;
所述存储器用于存储计算机可执行指令,所述处理器用于执行所述计算机可执行指令,以实现前面所述的方法。
一种可读存储介质,其上存储有指令,所述指令被执行以实现前面所述的方法。
本发明实施例提供的多任务并发处理方法及装置,采用多线程技术对多个子任务进行并行处理,在子任务之间存在依赖关系的情况下,利用任务树中各节点的服务状态及节点之间的父子关系,确定所述任务树中的待处理节点,为这些待处理节点分配线程处理对应的子任务。这样,对任务树中服务状态为等待状态并且父节点为空的节点对应的子任务启用多线程并行处理,并在子任务处理完成后可以及时释放所述子任务占用的线程,不会造成线程阻塞;而且,通过对任务树中各节点的服务状态及父节点的动态维护,使得任务树中的各节点可以按照节点间的依赖关系逐批执行,有效地避免了任务处理效率与资源占用这两者之间的冲突,在提高任务处理效率的同时,有效地避免了线程资源的浪费。
附图说明
为了更清楚地说明本申请实施例或现有技术中的技术方案,下面将对实施例中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本发明中记载的一些实施例,对于本领域普通技术人员来讲,还可以根据这些附图获得其他的附图。
图1是现有技术中利用CountDownLatch机制对并发服务进行管理的示意图;
图2是本发明实施例多任务并发处理方法的流程图;
图3是本发明实施例中任务树及线程池示例;
图4是利用本发明实施例多任务并发处理方法对并发服务进行管理的示意图;
图5是本发明实施例多任务并发处理装置的结构框图;
图6是根据一示例性实施例示出的一种用于多任务并发处理方法的装置的框图;
图7是本发明实施例中服务器的结构示意图。
具体实施方式
为了使本技术领域的人员更好地理解本发明实施例的方案,下面结合附图和实施方式对本发明实施例作进一步的详细说明。
针对利用多线程技术对多个子任务进行并行处理时,在子任务之间存在依赖关系的情况下利用现有的协调管理机制存在资源浪费的问题,本发明实施例提供一种多任务并发处理方法及装置,利用任务树中各节点的服务状态及节点之间的父子关系,确定所述任务树中的待处理节点,为这些待处理节点分配线程处理对应的子任务。
如图2所示,是本发明实施例多任务并发处理方法的流程图,包括以下步骤:
步骤201,确定任务树中的节点的服务状态及父节点。
在实际应用中,可以将一个服务拆分为多个子任务,这些子任务之间可以存在相互依赖关系,也就是说,其中一个子任务需要在另一个子任务执行完毕后才能执行,则将该另一个子任务作为该子任务的父节点,例如,节点a对应的子任务需要在节点b对应的子任务执行完成后才能执行,则将节点b作为节点a的父节点。当然,其中也有不依赖其它子任务即可执行的子任务。根据这些子任务之间的依赖关系构建相应的任务树,所述任务树中的每个节点对应一个子任务。
为了便于后续基于任务树确定分批执行的待处理节点的检测,在本发明实施例中,可以对所述任务树中的节点标注服务状态及父节点。一个节点对应的父节点可以不止一个。
需要说明的是,可以根据任务树中节点间的依赖关系确定节点对应的父节点,而且各节点的初始服务状态均设为等待状态。
在实际应用中,可以通过服务状态表来维护各节点的服务状态,通过节点关系表来维护各节点的父子关系,比如,每个节点维护一个服务状态表和一个父节点列表。当然,也可以将各节点的服务状态、父子关系信息综合在一个列表中,比如通过一个节点信息表来标记任务树中各节点的服务状态及父节点,对此本发明实施例不做限定。
步骤202,根据节点的所述服务状态及父节点确定所述节点是否为待处理节点。
针对任务树中的各节点,需要逐一确定该节点是否为待处理节点。具体地,可以检查所述节点是否满足处理条件,即:节点的父节点为空并且服务状态为等待状态;如果是,则确定所述节点为待处理节点。
步骤203,为所述待处理节点分配线程,以处理所述待处理节点对应的子任务。
需要说明的是,所述待处理节点可以有一个或多个,在有多个待处理节点的情况下,需要同时为这些待处理节点分配线程,也就是说,启用多线程以并行处理所述待处理节点对应的子任务。所述线程可以是线程池中未被占用的任意线程。
通过多线程的并行处理,可以有效提高任务的整体处理效率。
另外,在为所述待处理节点分配线程后,可以将所述待处理节点的服务状态设置为执行状态;在所述子任务处理完成后,还需要将所述子任务对应的节点的服务状态设置为完成状态,并将所述任务树中父节点中包含所述处理完成的子任务对应的节点移除,例如,节点c有两个父节点,分别为:节点a和节点b,若节点a对应的子任务执行完成,则将节点a从节点c的父节点中移除,节点c此时的父节点仅为节点b。若节点b对应的子任务执行完成,则将节点b从节点c的父节点中移除,此时节点c的父节点为空。
另外,在所述子任务处理完成后,所述子任务占用的线程即可被释放。
当然,如果任务树中已没有待处理节点,则说明所有的子任务均已被执行,无需再为任务树中节点启用线程来执行该节点对应的子任务。
通过上述过程,最终所述任务树中的所有节点对应的子任务都可以得到执行,并且,通过上述线程分配方法,在节点对应的父节点未执行完成的情况下,即父节点为非空的情况下,不会为该节点分配线程,避免该节点无法执行而占用线程,造成线程阻塞。
下面以图3所示的任务树及线程池为例,进一步举例详细说明利用本发明方法对线程的管理过程。
参照图4所示任务树节点的变化状态及子任务执行流程,具体过程如下:
在时刻t1,对任务树中各节点进行初始化,如图4中所示,该任务树中包含a、b、c、d、e五个节点,设置各节点的初始服务状态为等待状态,根据依赖关系确定各节点的父节点情况如下:节点a的父节点为空,节点b的父节点为节点a,节点c的父节点为节点a和节点b,节点d的父节点为空,节点e的父节点为节点c和节点d。
在时刻t2,根据各节点的服务状态以及父节点确定待处理节点。节点a、节点d的父节点为空,并且节点a、节点d的服务状态为等待状态,因此确定此t2时刻任务树中的待处理节点为节点a和节点d。从线程池中选择两个线程,比如线程1和线程2,将这两个线程各自分配给节点a、节点d,此时线程池中的其它线程还可以执行其它服务中的子任务,将节点a和节点d的服务状态修改为执行状态;使节点a对应的子任务a、节点d对应的子任务d并行执行;子任务a、子任务d执行完毕后,释放所占用的线程1和线程2,线程1和线程2回到线程池中,将节点a和节点d的服务状态修改为完成状态;由于节点a和节点d对应的子任务已完成,因此将任务树中父节点包含节点a和节点d的节点移除。其中,节点b的父节点中包含节点a,将节点b中的父节点a移除,则节点b的父节点为空;将节点c的父节点中包含的节点a移除,此时节点c的父节点更新为节点b;将节点e的父节点中包含的节点d移除,此时节点e的父节点更新为节点c。
在时刻t3,任务树中还剩节点b、节点c、节点e,其中,节点b的父节点为空,并且服务状态为等待状态,因此将节点b作为t3时刻的待处理节点,启动线程池中的一个线程执行节点b对应的子任务b,此时线程池中剩余的其它四个线程还可以执行其它服务中的子任务,将节点b的服务状态修改为执行状态;子任务b开始执行;子任务b执行完毕后,释放所占用的线程,将节点b的服务状态修改为完成状态;由于节点b对应的子任务已完成,因此将任务树中父节点包含节点b的移除,节点c的父节点中包含节点b,将节点c的父节点中的节点b移除,则节点c的父节点为空。
在时刻t4,任务树中还剩节点c和节点e,其中,节点c的父节点为空,并且服务状态为等待状态,因此将节点c作为t4时刻的待处理节点,启动线程池中的一个线程执行子任务c,此时线程池中剩余的其它四个线程还可以执行其它服务中的子任务,将节点c的服务状态修改为执行状态;节点c对应的子任务c开始执行;子任务c执行完毕后,释放所占用的线程,将节点c的服务状态修改为完成状态;由于节点c对应的子任务已完成,因此将任务树中父节点包含的节点c移除,节点e的父节点中包含节点c,将节点e的父节点中的节点c移除,则节点e的父节点为空。
在时刻t5,任务树中只剩节点e,节点e的父节点为空,并且服务状态为等待状态,因此将节点e作为t5时刻的待处理节点,启动线程池中的一个线程执行该节点e对应的子任务e,此时线程池中剩余的其它四个线程还可以执行其它服务中的子任务,将节点e的服务状态修改为执行状态;子任务e开始执行;子任务e执行完毕后,释放所占用的线程,将节点e的服务状态修改为完成状态;由于节点e对应的子任务已完成,因此将任务树中父节点包含的节点e移除。至此,任务树中所有节点对应的子任务均已执行完毕,整个服务完成。
可见,对存在依赖关系的子任务,利用本发明实施例提供的分批处理机制,不仅可以提高任务处理效率,而且可以有效地控制线程资源的启动和归还,进行资源的合理分配和使用,避免了线程资源的阻塞和浪费,提高了任务执行的吞吐率。
相应地,本发明实施例还提供一种多任务并发处理装置,如图5所示,是该装置的一种结构框图。
在该实施例中,所述装置包括以下各模块:
初始化模块501,用于确定任务树中的节点的服务状态及父节点;
待处理节点确定模块502,用于根据节点的所述服务状态及父节点确定所述节点是否为待处理节点;
线程管理模块503,用于为待处理节点分配线程,以处理所述待处理节点对应的子任务。
所述任务树可以根据子任务之间的依赖关系来构建,所述任务树中的每个节点对应一个子任务。
所述初始化模块501可以根据任务树中节点间的依赖关系确定节点对应的父节点,另外,可以将任务树中节点的初始服务状态设置为等待状态。
所述待处理节点确定模块502可以通过判断所述任务树中的各节点是否满足处理条件来确定是否为待处理节点,所述处理条件是指:节点的父节点为空并且服务状态为等待状态;如果满足所述处理条件,则确定所述节点为待处理节点。
相应地,线程管理模块503从线程池中选择空闲的线程,以处理所述待处理节点对应的子任务。需要说明的是,在所述待处理节点有多个时,线程管理模块503需要启动多线程以并行处理所述待处理节点对应的子任务,以提高任务的整体处理效率。
为了进一步提高上述各模块的独立性,在本发明多任务并发处理装置另一实施例中,还可以包括:
节点维护模块(未图示),用于在所述待处理节点分配线程后,将所述待处理节点的服务状态设置为执行状态;在所述子任务处理完成后,将所述子任务对应的节点的服务状态设置为完成状态。另外,在所述子任务处理完成后,所述节点维护模块还需要将所述任务树中父节点中包含所述处理完成的子任务对应的节点移除。
这样,利用任务树中各节点的服务状态及节点之间的父子关系,可以使上述线程管理模块503对线程的管理和待处理节点确定模块502对任务树中节点的检测独立进行,相互之间不需要任何依赖关系,进一步提高了本发明装置的灵活性。
本发明实施例提供的多任务并发处理装置,采用多线程技术对多个子任务进行并行处理,在子任务之间存在依赖关系的情况下,利用分批处理机制,为任务树中没有依赖关系的节点分配线程,对每批处理中的子任务采取多线程并行处理机制。通过对任务树中节点信息的动态维护,使得任务树中的各节点可以按照节点间的依赖关系逐批执行,有效地避免了任务处理效率与资源占用这两者之间的冲突,在提高任务处理效率的同时,有效地避免了线程资源的浪费。
图6是根据一示例性实施例示出的一种用于多任务并发处理方法的装置800的框图。例如,装置800可以是移动电话,计算机,数字广播终端,消息收发设备,游戏控制台,平板设备,医疗设备,健身设备,个人数字助理等。
参照图6,装置800可以包括以下一个或多个组件:处理组件802,存储器804,电源组件806,多媒体组件808,音频组件810,输入/输出(I/O)的接口812,传感器组件814,以及通信组件816。
处理组件802通常控制装置800的整体操作,诸如与显示,电话呼叫,数据通信,相机操作和记录操作相关联的操作。处理元件802可以包括一个或多个处理器820来执行指令,以完成上述的方法的全部或部分步骤。此外,处理组件802可以包括一个或多个模块,便于处理组件802和其他组件之间的交互。例如,处理部件802可以包括多媒体模块,以方便多媒体组件808和处理组件802之间的交互。
存储器804被配置为存储各种类别的数据以支持在设备800的操作。这些数据的示例包括用于在装置800上操作的任何应用程序或方法的指令,联系人数据,电话簿数据,消息,图片,视频等。存储器804可以由任何类别的易失性或非易失性存储设备或者它们的组合实现,如静态随机存取存储器(SRAM),电可擦除可编程只读存储器(EEPROM),可擦除可编程只读存储器(EPROM),可编程只读存储器(PROM),只读存储器(ROM),磁存储器,快闪存储器,磁盘或光盘。
电力组件806为装置800的各种组件提供电力。电力组件806可以包括电源管理系统,一个或多个电源,及其他与为装置800生成、管理和分配电力相关联的组件。
多媒体组件808包括在所述装置800和用户之间的提供一个输出接口的屏幕。在一些实施例中,屏幕可以包括液晶显示器(LCD)和触摸面板(TP)。如果屏幕包括触摸面板,屏幕可以被实现为触摸屏,以接收来自用户的输入信号。触摸面板包括一个或多个触摸传感器以感测触摸、滑动和触摸面板上的手势。所述触摸传感器可以不仅感测触摸或滑动动作的边界,而且还检测与所述触摸或滑动操作相关的持续时间和压力。在一些实施例中,多媒体组件808包括一个前置摄像头和/或后置摄像头。当设备800处于操作模式,如拍摄模式或视频模式时,前置摄像头和/或后置摄像头可以接收外部的多媒体数据。每个前置摄像头和后置摄像头可以是一个固定的光学透镜系统或具有焦距和光学变焦能力。
音频组件810被配置为输出和/或输入音频信号。例如,音频组件810包括一个麦克风(MIC),当装置800处于操作模式,如呼叫模式、记录模式和语音识别模式时,麦克风被配置为接收外部音频信号。所接收的音频信号可以被进一步存储在存储器804或经由通信组件816发送。在一些实施例中,音频组件810还包括一个扬声器,用于输出音频信号。
I/O接口812为处理组件802和外围接口模块之间提供接口,上述外围接口模块可以是键盘,点击轮,按钮等。这些按钮可包括但不限于:主页按钮、音量按钮、启动按钮和锁定按钮。
传感器组件814包括一个或多个传感器,用于为装置800提供各个方面的状态评估。例如,传感器组件814可以检测到设备800的打开/关闭状态,组件的相对定位,例如所述组件为装置800的显示器和小键盘,传感器组件814还可以检测装置800或装置800一个组件的位置改变,用户与装置800接触的存在或不存在,装置800方位或加速/减速和装置800的温度变化。传感器组件814可以包括接近传感器,被配置用来在没有任何的物理接触时检测附近物体的存在。传感器组件814还可以包括光传感器,如CMOS或CCD图像传感器,用于在成像应用中使用。在一些实施例中,该传感器组件814还可以包括加速度传感器,陀螺仪传感器,磁传感器,压力传感器或温度传感器。
通信组件816被配置为便于装置800和其他设备之间有线或无线方式的通信。装置800可以接入基于通信标准的无线网络,如WiFi,2G或3G,或它们的组合。在一个示例性实施例中,通信部件816经由广播信道接收来自外部广播管理系统的广播信号或广播相关信息。在一个示例性实施例中,所述通信部件816还包括近场通信(NFC)模块,以促进短程通信。例如,在NFC模块可基于射频识别(RFID)技术,红外数据协会(IrDA)技术,超宽带(UWB)技术,蓝牙(BT)技术和其他技术来实现。
在示例性实施例中,装置800可以被一个或多个应用专用集成电路(ASIC)、数字信号处理器(DSP)、数字信号处理设备(DSPD)、可编程逻辑器件(PLD)、现场可编程门阵列(FPGA)、控制器、微控制器、微处理器或其他电子元件实现,用于执行上述方法。
在示例性实施例中,还提供了一种包括指令的非临时性计算机可读存储介质,例如包括指令的存储器804,上述指令可由装置800的处理器820执行以完成上述按键误触纠错方法。例如,所述非临时性计算机可读存储介质可以是ROM、随机存取存储器(RAM)、CD-ROM、磁带、软盘和光数据存储设备等。
本发明还提供一种非临时性计算机可读存储介质,当所述存储介质中的指令由移动终端的处理器执行时,使得移动终端能够执行上述本发明方法实施例中的全部或部分步骤。
图7是本发明实施例中服务器的结构示意图。该服务器1900可因配置或性能不同而产生比较大的差异,可以包括一个或一个以上中央处理器(CentralProcessing Units,CPU)1922(例如,一个或一个以上处理器)和存储器1932,一个或一个以上存储应用程序1942或数据1944的存储介质1930(例如一个或一个以上海量存储设备)。其中,存储器1932和存储介质1930可以是短暂存储或持久存储。存储在存储介质1930的程序可以包括一个或一个以上模块(图示没标出),每个模块可以包括对服务器中的一系列指令操作。更进一步地,中央处理器1922可以设置为与存储介质1930通信,在服务器1900上执行存储介质1930中的一系列指令操作。
服务器1900还可以包括一个或一个以上电源1926,一个或一个以上有线或无线网络接口1950,一个或一个以上输入输出接口1958,一个或一个以上键盘1956,和/或,一个或一个以上操作系统1941,例如Windows ServerTM,Mac OS XTM,UnixTM,LinuxTM,FreeBSDTM等等。
显然,上面所描述的实施例仅仅是本发明一部分的实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都应当属于本发明保护的范围。
需要说明的是,本发明的说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象,而不必用于描述特定的顺序或先后次序。应该理解这样使用的数据在适当情况下可以互换,以便这里描述的本发明的实施例能够以除了在这里图示或描述的那些以外的顺序实施。此外,术语“包括”和“具有”以及他们的任何变形,意图在于覆盖不排他的包含,例如,包含了一系列步骤或单元的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元,而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。
本领域技术人员在考虑说明书及实践这里公开的发明后,将容易想到本发明的其它实施方案。本发明旨在涵盖本发明的任何变型、用途或者适应性变化,这些变型、用途或者适应性变化遵循本发明的一般性原理并包括本公开未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的,本发明的真正范围和精神由下面的权利要求指出。
应当理解的是,本发明并不局限于上面已经描述并在附图中示出的精确结构,并且可以在不脱离其范围进行各种修改和改变。本发明的范围仅由所附的权利要求来限制。
以上所述仅为本发明的较佳实施例,并不用以限制本发明,凡在本发明的精神和原则之内,所作的任何修改、等同替换、改进等,均应包含在本发明的保护范围之内。
Claims (10)
1.一种多任务并发处理方法,其特征在于,所述方法包括:
确定任务树中的节点的服务状态及父节点;
根据节点的所述服务状态及父节点确定所述节点是否为待处理节点;
为待处理节点分配线程,以处理所述待处理节点对应的子任务。
2.根据权利要求1所述的方法,其特征在于,所述确定任务树中的节点的服务状态包括:
将任务树中节点的初始服务状态设置为等待状态。
3.根据权利要求1所述的方法,其特征在于,所述确定任务树中的节点的父节点包括:
根据任务树中节点间的依赖关系确定节点对应的父节点。
4.根据权利要求1所述的方法,其特征在于,所述根据节点的所述服务状态及父节点确定所述节点是否为待处理节点包括:
判断节点的父节点是否为空并且服务状态是否为等待状态;
如果是,则确定所述节点为待处理节点。
5.根据权利要求1所述的方法,其特征在于,所述为所述待处理节点分配线程,以处理所述待处理节点对应的子任务包括:
如果所述待处理节点有多个,则启用多线程以并行处理所述待处理节点对应的子任务。
6.根据权利要求1至5任一项所述的方法,其特征在于,所述方法还包括:
为所述待处理节点分配线程后,将所述待处理节点的服务状态设置为执行状态;
在所述子任务处理完成后,将所述子任务对应的节点的服务状态设置为完成状态。
7.根据权利要求1所述的方法,其特征在于,在所述子任务处理完成后,所述方法还包括:
将所述任务树中父节点中包含所述处理完成的子任务对应的节点移除。
8.一种多任务并发处理装置,其特征在于,所述装置包括:
初始化模块,用于确定任务树中的节点的服务状态及父节点;
待处理节点确定模块,用于根据节点的所述服务状态及父节点确定所述节点是否为待处理节点;
线程管理模块,用于为待处理节点分配线程,以处理所述待处理节点对应的子任务。
9.一种电子设备,其特征在于,包括:一个或多个处理器、存储器;
所述存储器用于存储计算机可执行指令,所述处理器用于执行所述计算机可执行指令,以实现如权利要求1至7任一项所述的方法。
10.一种可读存储介质,其上存储有指令,所述指令被执行以实现如权利要求1至7任一项所述的方法。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910168719.9A CN111666146A (zh) | 2019-03-06 | 2019-03-06 | 多任务并发处理方法及装置 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910168719.9A CN111666146A (zh) | 2019-03-06 | 2019-03-06 | 多任务并发处理方法及装置 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111666146A true CN111666146A (zh) | 2020-09-15 |
Family
ID=72381377
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201910168719.9A Pending CN111666146A (zh) | 2019-03-06 | 2019-03-06 | 多任务并发处理方法及装置 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111666146A (zh) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112306713A (zh) * | 2020-10-30 | 2021-02-02 | 深圳前海微众银行股份有限公司 | 一种任务的并发计算方法及装置、设备、存储介质 |
| CN118567796A (zh) * | 2023-07-06 | 2024-08-30 | 滴图(北京)科技有限公司 | 用于处理工作流的方法和装置 |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8209702B1 (en) * | 2007-09-27 | 2012-06-26 | Emc Corporation | Task execution using multiple pools of processing threads, each pool dedicated to execute different types of sub-tasks |
| WO2016028425A1 (en) * | 2014-08-21 | 2016-02-25 | Qualcomm Incorporated | Programmatic decoupling of task execution from task finish in parallel programs |
| CN107341054A (zh) * | 2017-06-29 | 2017-11-10 | 广州市百果园信息技术有限公司 | 任务执行方法、装置及计算机可读存储介质 |
| CN108287756A (zh) * | 2018-01-25 | 2018-07-17 | 联动优势科技有限公司 | 一种处理任务的方法及装置 |
| CN108509284A (zh) * | 2018-03-08 | 2018-09-07 | 华南理工大学 | 一种应用于函数式编程的树状模型任务管理系统 |
-
2019
- 2019-03-06 CN CN201910168719.9A patent/CN111666146A/zh active Pending
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8209702B1 (en) * | 2007-09-27 | 2012-06-26 | Emc Corporation | Task execution using multiple pools of processing threads, each pool dedicated to execute different types of sub-tasks |
| WO2016028425A1 (en) * | 2014-08-21 | 2016-02-25 | Qualcomm Incorporated | Programmatic decoupling of task execution from task finish in parallel programs |
| CN107341054A (zh) * | 2017-06-29 | 2017-11-10 | 广州市百果园信息技术有限公司 | 任务执行方法、装置及计算机可读存储介质 |
| CN108287756A (zh) * | 2018-01-25 | 2018-07-17 | 联动优势科技有限公司 | 一种处理任务的方法及装置 |
| CN108509284A (zh) * | 2018-03-08 | 2018-09-07 | 华南理工大学 | 一种应用于函数式编程的树状模型任务管理系统 |
Non-Patent Citations (1)
| Title |
|---|
| 郭敏;周亮;王中庆;王宇鹏;白懿鹏;吕飞鹏;: "基于多任务异步处理的电力系统序网络拓扑分析", 电测与仪表, no. 05, 10 March 2016 (2016-03-10), pages 27 - 32 * |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112306713A (zh) * | 2020-10-30 | 2021-02-02 | 深圳前海微众银行股份有限公司 | 一种任务的并发计算方法及装置、设备、存储介质 |
| CN118567796A (zh) * | 2023-07-06 | 2024-08-30 | 滴图(北京)科技有限公司 | 用于处理工作流的方法和装置 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN114138439A (zh) | 任务调度方法及装置、电子设备和存储介质 | |
| CN106339260B (zh) | 基于Jenkins平台的任务分配方法及装置 | |
| CN109254849B (zh) | 应用程序的运行方法及装置 | |
| CN113268325B (zh) | 一种调度任务的方法、装置及存储介质 | |
| CN109861966B (zh) | 处理状态事件的方法、装置、终端及存储介质 | |
| CN108958911B (zh) | 进程的控制方法及装置 | |
| CN105930213A (zh) | 应用运行方法及装置 | |
| CN116048757A (zh) | 任务处理方法、装置、电子设备和存储介质 | |
| CN114153582A (zh) | 资源调度方法及装置、电子设备和存储介质 | |
| CN113360254A (zh) | 任务调度方法及系统 | |
| CN112286687B (zh) | 一种资源处理方法及装置 | |
| CN117193963A (zh) | 基于函数特征的服务器无感知计算调度方法和装置 | |
| CN111666146A (zh) | 多任务并发处理方法及装置 | |
| CN112486658B (zh) | 一种任务调度方法、装置和用于任务调度的装置 | |
| WO2023273025A1 (zh) | 任务处理系统、电子设备和存储介质 | |
| CN106533798B (zh) | 检测方法和装置 | |
| CN115671715A (zh) | 云游戏的资源调度方法、装置、系统和电子设备 | |
| CN106502740B (zh) | 应用安装方法和装置 | |
| CN110362405B (zh) | 应用程序的线程分配方法、装置、设备及可读存储介质 | |
| WO2017128664A1 (zh) | 进程调用的方法及装置 | |
| CN106020939A (zh) | 删除锁的方法、装置和用于删除锁的装置 | |
| CN104391742A (zh) | 应用优化方法和装置 | |
| CN108984294A (zh) | 资源调度方法、装置及存储介质 | |
| CN111198760B (zh) | 一种数据处理方法和装置 | |
| CN114612287A (zh) | 图像处理方法、装置及存储介质 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination |