一种多队列任务并行计算方法、装置、设备及介质与流程

allin2023-03-16  124



1.本发明涉及软件多任务并行计算领域,特别涉及一种多队列任务并行计算方法、装置、设备及介质。


背景技术:

2.在面向一个区域中多个无线电台同时进行电磁兼容分析计算的软件设计过中,每个无线电台均涉及电磁兼容分析计算。电磁兼容分析计算过程复杂,计算量大,且存在多任务并发处理的需求。目前,由于是面向集群环境设计的框架,所以系统相对庞大、复杂,系统自身的运行本身就要占用较多的计算资源,面对电磁兼容分析的复杂计算,没有针对具体无线电业务场景开展计算编排的设计,因此计算效率偏低,面向集群节点的设计,并没有考虑单机多核cpu(中央处理器,central processing unit)本身的计算能力,没能最大化地发挥单机cpu的计算资源的效能。
3.由上可见,在多队列任务并行计算的过程中,如何最大化发挥多核计算能力,并提高电磁兼容计算任务并行计算的效率,满足业务需求的多样性是本领域有待解决的问题。


技术实现要素:

4.有鉴于此,本发明的目的在于提供一种多队列任务并行计算方法、装置、设备及介质,能够最大化发挥多核计算能力,并提高电磁兼容计算任务并行计算的效率,满足业务需求的多样性。其具体方案如下:
5.第一方面,本技术公开了一种多队列任务并行计算方法,包括:
6.获取各无线电台的电磁兼容计算任务并保存至第一任务队列;
7.通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;
8.通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。
9.可选的,所述通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,包括:
10.获取无线电台的电磁兼容业务需求,并基于所述电磁兼容业务需求确定出任务分类方法;
11.利用所述任务分类方法并通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类。
12.可选的,所述通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备,包括:
13.基于所述预设单线程的运行时间数量级、所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间,确定出所述电磁兼容计算任务的发送数量;
14.通过所述第一任务队列并基于所述电磁兼容计算任务的发送数量,将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个所述第二任务队列的单机任务处理设备。
15.可选的,所述确定出所述电磁兼容计算任务的发送数量之前,还包括:
16.将所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间发送至所述第一任务队列。
17.可选的,所述确定出所述电磁兼容计算任务的发送数量之前,还包括:
18.对所述第一任务队列中所有的所述电磁兼容计算任务的任务数量进行预估,以得到任务数量预估值;
19.基于所述任务数量预估值确定出所述预设单线程的运行时间数量级。
20.可选的,所述确定出所述电磁兼容计算任务的发送数量之前,还包括:
21.确定出所述第二任务队列中当前剩余未处理任务的任务数量,并确定出每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间;
22.计算所述总排队时间与所述第二任务队列中当前剩余未处理任务的任务数量的比值,以得到每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间。
23.可选的,所述多队列任务并行计算方法,还包括:
24.获取多核cpu信息以及运行系统信息;
25.基于所述多核cpu信息以及所述运行系统信息在所述单机任务处理设备中创建多个第二任务队列。
26.第二方面,本技术公开了一种多队列任务并行计算装置,包括:
27.计算任务保存模块,用于获取各无线电台的电磁兼容计算任务并保存至第一任务队列;
28.计算任务分类模块,用于通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;
29.任务计算模块,用于通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。
30.第三方面,本技术公开了一种电子设备,包括:
31.存储器,用于保存计算机程序;
32.处理器,用于执行所述计算机程序,以实现前述的多队列任务并行计算方法。
33.第四方面,本技术公开了一种计算机存储介质,用于保存计算机程序;其中,所述计算机程序被处理器执行时实现前述公开的多队列任务并行计算方法的步骤。
34.可见,本技术提供了一种多队列任务并行计算方法,包括获取各无线电台的电磁兼容计算任务并保存至第一任务队列;通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。本技术通过对电磁兼容计算任务进行分类,能够满足业务需求的多样性,利用预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备对电磁兼容计算任务进行并行计算处理,能够最大化发挥多核计算能力,并有效提高电磁兼容计算任务并行计算的效率。
附图说明
35.为了更清楚地说明本发明实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本发明的实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据提供的附图获得其他的附图。
36.图1为本技术公开的一种多队列任务并行计算方法流程图;
37.图2为本技术公开的一种多队列任务并行计算方法流程图;
38.图3为本技术公开的一种多队列任务并行计算方法具体流程图;
39.图4为本技术公开的一种多队列任务并行计算装置结构示意图;
40.图5为本技术提供的一种电子设备结构图。
具体实施方式
41.下面将结合本发明实施例中的附图,对本发明实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。
42.在当前背景下,在面向一个区域中多个无线电台同时进行电磁兼容分析计算的软件设计过中,每个无线电台均涉及电磁兼容分析计算。电磁兼容分析计算过程复杂,计算量大,且存在多任务并发处理的需求。目前,由于是面向集群环境设计的框架,所以系统相对庞大、复杂,系统自身的运行本身就要占用较多的计算资源,面对电磁兼容分析的复杂计算,没有针对具体无线电业务场景开展计算编排的设计,因此计算效率偏低,面向集群节点的设计,并没有考虑单机多核cpu(中央处理器,central processing unit)本身的计算能力,没能最大化地发挥单机cpu的计算资源的效能。由上可见,在多队列任务并行计算的过程中,如何最大化发挥多核计算能力,并提高电磁兼容任务并行计算效率,满足业务需求的多样性是本领域有待解决的问题。
43.参见图1所示,本发明实施例公开了一种多队列任务并行计算方法,具体可以包括:
44.步骤s11:获取各无线电台的电磁兼容计算任务并保存至第一任务队列。
45.步骤s12:通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务。
46.步骤s13:通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。
47.本实施例中,基于所述预设单线程的运行时间数量级、所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间,确定出所述电磁兼容计算任务的发送数量,然后通过所述第一任务队列并基于所述电磁兼容计算任务的发送数量,将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个所述第二任务队列的单机任务处理设备。
48.本实施例中,在通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备之前,还包括通过对所述第一任务队列中所有的所述电磁兼容计算任务的任务数量进行预估,以得到任务数量预估值,然后基于所述任务数量预估值确定出所述预设单线程的运行时间数量级;确定出所述第二任务队列中当前剩余未处理任务的任务数量,并确定出每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间,计算所述总排队时间与所述第二任务队列中当前剩余未处理任务的任务数量的比值,以得到每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间;然后将所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间发送至所述第一任务队列。
49.本实施例中,获取各无线电台的电磁兼容计算任务并保存至第一任务队列;通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。本技术通过对电磁兼容计算任务进行分类,能够满足业务需求的多样性,利用预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备对电磁兼容计算任务进行并行计算处理,能够最大化发挥多核计算能力,并有效提高电磁兼容计算任务并行计算的效率。
50.参见图2所示,本发明实施例公开了一种多队列任务并行计算方法,具体可以包括:
51.步骤s21:获取各无线电台的电磁兼容计算任务并保存至第一任务队列。
52.步骤s22:获取无线电台的电磁兼容业务需求,并基于所述电磁兼容业务需求确定出任务分类方法,然后利用所述任务分类方法并通过预设单线程对所述第一任务队列里的
所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务。
53.步骤s23:通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。
54.本实施例中,基于多核cpu构建并设有多个第二任务队列的单机任务处理设备具体包括:获取多核cpu信息以及运行系统信息,然后基于所述多核cpu信息以及所述运行系统信息在所述单机任务处理设备中创建多个第二任务队列。
55.本实施例中,获取各无线电台的电磁兼容计算任务并保存至第一任务队列;通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。本技术通过对电磁兼容计算任务进行分类,能够满足业务需求的多样性,利用预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备对电磁兼容计算任务进行并行计算处理,能够最大化发挥多核计算能力,并有效提高电磁兼容计算任务并行计算的效率。
56.例如,如图3所示,将客户机发送的各无线电台的电磁兼容计算任务保存至第一任务队列,然后对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务,对所述第一任务队列中所有的所述电磁兼容计算任务的任务数量进行预估,以得到任务数量预估值,并基于所述任务数量预估值确定出所述预设单线程的运行时间数量级,然后确定出所述第二任务队列中当前剩余未处理任务的任务数量,并确定出每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间,计算所述总排队时间与所述第二任务队列中当前剩余未处理任务的任务数量的比值,以得到每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间,然后将所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间发送至所述第一任务队列,将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。
57.参见图4所示,本发明实施例公开了一种多队列任务并行计算装置,具体可以包括:
58.计算任务保存模块,用于获取各无线电台的电磁兼容计算任务并保存至第一任务队列;
59.计算任务分类模块,用于通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;
60.任务计算模块,用于通过所述第一任务队列将不同种类的所述电磁兼容计算任务
发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。
61.本实施例中,获取各无线电台的电磁兼容计算任务并保存至第一任务队列;通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。本技术通过对电磁兼容计算任务进行分类,能够满足业务需求的多样性,利用预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备对电磁兼容计算任务进行并行计算处理,能够最大化发挥多核计算能力,并有效提高电磁兼容计算任务并行计算的效率。
62.在一些具体实施例中,所述计算任务分类模块12,具体可以包括:
63.分类方法确定模块,用于获取无线电台的电磁兼容业务需求,并基于所述电磁兼容业务需求确定出任务分类方法;
64.计算任务分类模块,用于利用所述任务分类方法并通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类。
65.在一些具体实施例中,所述任务计算模块13,具体可以包括:
66.发送数量确定模块,用于基于所述预设单线程的运行时间数量级、所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间,确定出所述电磁兼容计算任务的发送数量;
67.任务计算模块,用于通过所述第一任务队列并基于所述电磁兼容计算任务的发送数量,将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个所述第二任务队列的单机任务处理设备。
68.在一些具体实施例中,所述任务计算模块13,具体可以包括:
69.发送模块,用于将所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间发送至所述第一任务队列。
70.在一些具体实施例中,所述任务计算模块13,具体可以包括:
71.任务数量预估值确定模块,用于对所述第一任务队列中所有的所述电磁兼容计算任务的任务数量进行预估,以得到任务数量预估值;
72.运行时间数量级确定模块,用于基于所述任务数量预估值确定出所述预设单线程的运行时间数量级。
73.在一些具体实施例中,所述任务计算模块13,具体可以包括:
74.总排队时间确定模块,用于确定出所述第二任务队列中当前剩余未处理任务的任务数量,并确定出每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时
间;
75.平均排队时间确定模块,用于计算所述总排队时间与所述第二任务队列中当前剩余未处理任务的任务数量的比值,以得到每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间。
76.在一些具体实施例中,所述任务计算模块13,具体可以包括:
77.信息获取模块,用于获取多核cpu信息以及运行系统信息;
78.第二任务队列创建模块,用于基于所述多核cpu信息以及所述运行系统信息在所述单机任务处理设备中创建多个第二任务队列。
79.图5为本技术实施例提供的一种电子设备的结构示意图。该电子设备20,具体可以包括:至少一个处理器21、至少一个存储器22、电源23、通信接口24、输入输出接口25和通信总线26。其中,所述存储器22用于存储计算机程序,所述计算机程序由所述处理器21加载并执行,以实现前述任一实施例公开的由电子设备执行的多队列任务并行计算方法中的相关步骤。
80.本实施例中,电源23用于为电子设备20上的各硬件设备提供工作电压;通信接口24能够为电子设备20创建与外界设备之间的数据传输通道,其所遵循的通信协议是能够适用于本技术技术方案的任意通信协议,在此不对其进行具体限定;输入输出接口25,用于获取外界输入数据或向外界输出数据,其具体的接口类型可以根据具体应用需要进行选取,在此不进行具体限定。
81.另外,存储器22作为资源存储的载体,可以是只读存储器、随机存储器、磁盘或者光盘等,其上所存储的资源包括操作系统221、计算机程序222及数据223等,存储方式可以是短暂存储或者永久存储。
82.其中,操作系统221用于管理与控制电子设备20上的各硬件设备以及计算机程序222,以实现处理器21对存储器22中数据223的运算与处理,其可以是windows、unix、linux等。计算机程序222除了包括能够用于完成前述任一实施例公开的由电子设备20执行的多队列任务并行计算方法的计算机程序之外,还可以进一步包括能够用于完成其他特定工作的计算机程序。数据223除了可以包括多队列任务并行计算设备接收到的由外部设备传输进来的数据,也可以包括由自身输入输出接口25采集到的数据等。
83.结合本文中所公开的实施例描述的方法或算法的步骤可以直接用硬件、处理器执行的软件模块,或者二者的结合来实施。软件模块可以置于随机存储器(ram)、内存、只读存储器(rom)、电可编程rom、电可擦除可编程rom、寄存器、硬盘、可移动磁盘、cd-rom、或技术领域内所公知的任意其它形式的存储介质中。
84.进一步的,本技术实施例还公开了一种计算机可读存储介质,所述存储介质中存储有计算机程序,所述计算机程序被处理器加载并执行时,实现前述任一实施例公开的多队列任务并行计算方法步骤。
85.最后,还需要说明的是,在本文中,诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来,而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者
设备所固有的要素。在没有更多限制的情况下,由语句“包括一个
……”
限定的要素,并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。
86.以上对本发明所提供的一种多队列任务并行计算方法、装置、设备及存储介质进行了详细介绍,本文中应用了具体个例对本发明的原理及实施方式进行了阐述,以上实施例的说明只是用于帮助理解本发明的方法及其核心思想;同时,对于本领域的一般技术人员,依据本发明的思想,在具体实施方式及应用范围上均会有改变之处,综上所述,本说明书内容不应理解为对本发明的限制。

技术特征:
1.一种多队列任务并行计算方法,其特征在于,包括:获取各无线电台的电磁兼容计算任务并保存至第一任务队列;通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。2.根据权利要求1所述的多队列任务并行计算方法,其特征在于,所述通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,包括:获取无线电台的电磁兼容业务需求,并基于所述电磁兼容业务需求确定出任务分类方法;利用所述任务分类方法并通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类。3.根据权利要求1所述的多队列任务并行计算方法,其特征在于,所述通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备,包括:基于所述预设单线程的运行时间数量级、所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间,确定出所述电磁兼容计算任务的发送数量;通过所述第一任务队列并基于所述电磁兼容计算任务的发送数量,将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个所述第二任务队列的单机任务处理设备。4.根据权利要求3所述的多队列任务并行计算方法,其特征在于,所述确定出所述电磁兼容计算任务的发送数量之前,还包括:将所述第二任务队列中当前剩余未处理任务的任务数量、每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间以及每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间发送至所述第一任务队列。5.根据权利要求3所述的多队列任务并行计算方法,其特征在于,所述确定出所述电磁兼容计算任务的发送数量之前,还包括:对所述第一任务队列中所有的所述电磁兼容计算任务的任务数量进行预估,以得到任务数量预估值;基于所述任务数量预估值确定出所述预设单线程的运行时间数量级。6.根据权利要求3所述的多队列任务并行计算方法,其特征在于,所述确定出所述电磁兼容计算任务的发送数量之前,还包括:确定出所述第二任务队列中当前剩余未处理任务的任务数量,并确定出每个所述第二任务队列中的所有所述当前剩余未处理任务的总排队时间;
计算所述总排队时间与所述第二任务队列中当前剩余未处理任务的任务数量的比值,以得到每个所述第二任务队列中的每个所述当前剩余未处理任务的平均排队时间。7.根据权利要求1至6任一项所述的多队列任务并行计算方法,其特征在于,还包括:获取多核cpu信息以及运行系统信息;基于所述多核cpu信息以及所述运行系统信息在所述单机任务处理设备中创建多个第二任务队列。8.一种多队列任务并行计算装置,其特征在于,包括:计算任务保存模块,用于获取各无线电台的电磁兼容计算任务并保存至第一任务队列;计算任务分类模块,用于通过预设单线程对所述第一任务队列里的所述电磁兼容计算任务进行分类,以得到不同种类的所述电磁兼容计算任务;任务计算模块,用于通过所述第一任务队列将不同种类的所述电磁兼容计算任务发送至预先基于多核cpu构建并设有多个第二任务队列的单机任务处理设备;其中,所述单机任务处理设备基于预设映射关系将接收到的不同种类的所述电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个所述第二任务队列对获取到的所述电磁兼容计算任务进行并行计算处理。9.一种电子设备,其特征在于,包括:存储器,用于保存计算机程序;处理器,用于执行所述计算机程序,以实现如权利要求1至7任一项所述的多队列任务并行计算方法。10.一种计算机可读存储介质,其特征在于,用于保存计算机程序;其中,所述计算机程序被处理器执行时实现如权利要求1至7任一项所述的多队列任务并行计算方法。

技术总结
本申请公开了一种多队列任务并行计算方法、装置、设备及介质,涉及软件多任务并行计算领域,包括:获取各无线电台的电磁兼容计算任务并保存至第一任务队列;通过预设单线程对第一任务队列里的电磁兼容计算任务进行分类;通过第一任务队列将不同种类的电磁兼容计算任务发送至预先基于多核CPU构建并设有多个第二任务队列的单机任务处理设备;其中,单机任务处理设备基于预设映射关系将接收到的不同种类的电磁兼容计算任务分别发送至相应的所述第二任务队列,以便通过多个第二任务队列对获取到的电磁兼容计算任务进行并行计算处理。通过本申请的上述技术方案,能够最大化发挥多核计算能力,提高电磁兼容计算任务并行计算的效率,满足业务需求多样性。满足业务需求多样性。满足业务需求多样性。


技术研发人员:夏亮 胡谦 孙宇
受保护的技术使用者:北京波尔通信技术股份有限公司
技术研发日:2022.04.11
技术公布日:2022/7/5
转载请注明原文地址: https://www.8miu.com/read-6159.html

最新回复(0)