1.一种工业互联网平台的任务处理方法,其特征在于,所述方法包括:获取待处理任务和可调配线程数量;
根据待处理任务查询预设的任务处理模版,划分任务处理阶段;
根据任务处理模版确定各个任务处理阶段线程分配比例,根据可调配线程数据进行线程分配,并进行任务动态处理;
计算各个任务处理阶段对应的线程空闲率,根据线程空闲率进行线程分配调节,直至任务处理完成;
所述根据待处理任务查询预设的任务处理模版,划分任务处理阶段的步骤,具体包括:识别待处理任务,确定任务类型、任务执行数据源以及任务处理结果存储地址;
基于任务类型查询模版数据库,查询得到对应的任务处理模版;
根据任务处理模版确定各个任务处理步骤,划分任务处理阶段,确定各个任务处理阶段的数据处理顺序;
所述计算各个任务处理阶段对应的线程空闲率,根据线程空闲率进行线程分配调节,直至任务处理完成的步骤,具体包括:独立统计各个任务处理阶段对应的线程空闲率;
计算各个任务处理阶段的待处理数据量,计算各个任务处理阶段对应的单线程处理速度;
基于各任务处理阶段对应的单线程处理速度对各个任务处理阶段分配的线程进行数量调整,直至任务处理完成。
2.根据权利要求1所述的工业互联网平台的任务处理方法,其特征在于,所述根据任务处理模版确定各个任务处理阶段线程分配比例,根据可调配线程数据进行线程分配,并进行任务动态处理的步骤,具体包括:根据数据处理顺序确定并行任务阶段和串行任务阶段,所述并行任务阶段包含至少两个可并行处理的任务处理阶段;
查询任务处理模版,为所有并行任务阶段和串行任务阶段分配对应的固定线程,并预留至少一个线程作为活动线程;
通过固定线程执行各并行任务阶段和串行任务阶段,根据固定线程的空闲率对活动线程进行动态调配。
3.根据权利要求1所述的工业互联网平台的任务处理方法,其特征在于,当任一任务处理阶段的数据积压量超过预设值时,重新进行线程分配。
4.根据权利要求1所述的工业互联网平台的任务处理方法,其特征在于,处于同一处理顺序的并行任务阶段对应的固定线程允许相互调用。
5.一种工业互联网平台的任务处理系统,其特征在于,所述系统包括:数据获取模块,用于获取待处理任务和可调配线程数量;
任务拆分模块,用于根据待处理任务查询预设的任务处理模版,划分任务处理阶段;
线程分配模块,用于根据任务处理模版确定各个任务处理阶段线程分配比例,根据可调配线程数据进行线程分配,并进行任务动态处理;
线程动态调节模块,用于计算各个任务处理阶段对应的线程空闲率,根据线程空闲率进行线程分配调节,直至任务处理完成;
所述任务拆分模块包括:
任务识别单元,用于识别待处理任务,确定任务类型、任务执行数据源以及任务处理结果存储地址;
数据查询单元,用于基于任务类型查询模版数据库,查询得到对应的任务处理模版;
阶段拆分单元,用于根据任务处理模版确定各个任务处理步骤,划分任务处理阶段,确定各个任务处理阶段的数据处理顺序;
所述线程动态调节模块包括:
空闲率计算单元,用于独立统计各个任务处理阶段对应的线程空闲率;
信息计算单元,用于计算各个任务处理阶段的待处理数据量,计算各个任务处理阶段对应的单线程处理速度;
线程调节单元,用于基于各任务处理阶段对应的单线程处理速度对各个任务处理阶段分配的线程进行数量调整,直至任务处理完成。
6.根据权利要求5所述的工业互联网平台的任务处理系统,其特征在于,所述线程分配模块包括:任务分类单元,用于根据数据处理顺序确定并行任务阶段和串行任务阶段,所述并行任务阶段包含至少两个可并行处理的任务处理阶段;
线程匹配单元,用于查询任务处理模版,为所有并行任务阶段和串行任务阶段分配对应的固定线程,并预留至少一个线程作为活动线程;
动态调节单元,用于通过固定线程执行各并行任务阶段和串行任务阶段,根据固定线程的空闲率对活动线程进行动态调配。