-
公开(公告)号:CN107798016B
公开(公告)日:2019-06-07
申请号:CN201610805758.1
申请日:2016-09-06
Applicant: 北京百度网讯科技有限公司
IPC: G06F16/27
CPC classification number: G06F9/546 , G06F9/52 , G06F11/3024 , G06F11/3055 , Y10S901/50
Abstract: 本申请公开了用于机器人操作系统的数据传输方法和装置。所述机器人操作系统包括发送节点、接收节点和作为所述发送节点与所述接收节点间传输介质的共享内存,所述方法的一具体实施方式包括:所述发送节点遍历预先存储在所述共享内存中的数据模板序列,确定所述数据模板序列中的各个数据模板当前是否被写入或被读取;将所述数据模板序列中当前未被写入且未被读取的数据模板作为目标数据模板,获取所述目标数据模板的信息;根据所述目标数据模板的信息,在所述目标数据模板中写入数据。该实施方式实现了在占用更少的内存资源的情况下,提高数据传输的传输性能。
-
公开(公告)号:CN106104488B
公开(公告)日:2019-06-07
申请号:CN201580014125.2
申请日:2015-03-05
Applicant: 高通股份有限公司
Inventor: 阿列克谢·弗拉狄米罗维奇·布尔德 , 司瓦浦奈尔·普拉迪普库尔马·沙克哈雪特 , 徐飞
CPC classification number: G06F12/023 , G06F9/526 , G06F9/54 , G06F9/546
Abstract: 本发明描述用于支持并行计算系统中的任务间通信的技术。所述用于支持任务间通信的技术可使用基于硬件的原子操作来维持管线的状态。管线可指代先入先出FIFO组织的缓冲器,其允许各种任务作为数据产生者或数据消费者而与缓冲器交互。各种管线实施方案可使用多个状态参数来界定管线的状态。本发明中所描述的所述基于硬件的原子操作可以原子方式修改多个管线状态参数。以原子方式修改多个管线状态参数可避免竞态条件,当多个产生者和/或多个消费者同时尝试修改管线的状态时原本将发生所述竞态条件。以此方式,可在并行计算系统中支持基于管线的任务间通信。
-
公开(公告)号:CN109791499A
公开(公告)日:2019-05-21
申请号:CN201780058808.7
申请日:2017-09-20
Applicant: 瑞典爱立信有限公司
CPC classification number: H04L51/04 , G06F9/45533 , G06F9/46 , G06F9/542 , G06F9/546 , G06F21/53 , H04L5/14 , H04L51/16 , H04L63/105 , H04L67/10 , H04L67/141 , H04L67/22 , H04L67/26 , H04L67/306
Abstract: 一种实现平台的事件服务系统和方法。平台执行一组容器和一组组件服务以支持该组容器。该方法跟踪事件的订户并促进事件向订户的分发。事件包括有关该组容器中的至少一个容器的状态的改变的信息,其中,订户是与平台通信的进程。该方法包括:在事件服务处接收订阅该组容器中的容器的事件的订户请求;在事件服务处从平台的该组组件服务中的组件服务接收事件;以及由事件服务向订户发送该事件。
-
公开(公告)号:CN109684091A
公开(公告)日:2019-04-26
申请号:CN201811581669.9
申请日:2018-12-24
Applicant: 杭州迪普科技股份有限公司
Inventor: 李绍辉
CPC classification number: G06F9/5027 , G06F9/466 , G06F9/546
Abstract: 公开了一种任务处理方法及装置。一种任务处理方法,其特征在于,生产者线程预先创建包括至少1个消费者线程的线程池,所述方法包括:所述生产者线程监听是否产生新的连接请求,并且在监听到新的连接请求的情况下,基于Epoll技术新建任务;所述生产者线程根据预设任务分发规则,从所述线程池中确定符合该规则的任一消费者线程,将所新建的任务基于Epoll技术分发至该消费者线程;所述消费者线程基于Epoll技术确定是否接收到所述生产者线程分发的任务,并在接收到任务后,执行所接收的任务;所述消费者线程在完成所接收任务的情况下,确定该任务对应的连接是否关闭,若是,则结束该任务,若否,则保持持有该任务。
-
公开(公告)号:CN109634843A
公开(公告)日:2019-04-16
申请号:CN201811285022.1
申请日:2018-10-31
Applicant: 中国科学院软件研究所
CPC classification number: G06F11/3692 , G06F9/546 , G06F11/3664 , G06F11/3688 , G06F2209/548
Abstract: 本发明公开了一种面向AI芯片平台的分布式自动化软件测试方法及平台。该平台可以通过服务器将AI软件测试任务自动化的分发给不同的AI芯片平台客户端计算机去运行,测试完成后将测试结果统一到服务器管理,然后根据需求自动发布环境更新任务并随后向X86客户端发起第二次相同的测试任务,该任务在X86客户端上进行纯软件运行,并统一收集管理第二次的测试结果。当两次测试工作结束后,会自动的对两次的测试结果进行对比分析,并输出分析结果;并且,对前后两次离线模型的改变进行追溯,定位离线模型的结点或者输入导致错误,帮助软件工程师和硬件工程师排查问题。
-
公开(公告)号:CN109634800A
公开(公告)日:2019-04-16
申请号:CN201811226175.9
申请日:2018-10-19
Applicant: 深圳平安财富宝投资咨询有限公司
CPC classification number: G06F11/3065 , G06F9/546 , G06F9/547 , G06F11/3006 , G06F2201/80 , G06F2201/875
Abstract: 本发明提供一种数据处理方法、系统、终端及可读存储介质,数据处理方法包括:从第一消息列队中获取目标消息;向日志数据库发送目标消息,目标消息包括任务节点信息;从任务节点信息获取目标消息的微服务接口和目标消息的请求参数;根据微服务接口将请求参数发送至对应的微服务接收方,以使得微服务接收方执行目标消息;接收微服务接收方的反馈结果,并根据反馈结果向日志数据库发送第一类状态变更通知,以使得日志数据库变更目标消息的任务节点信息。本实施例通过设置一个日志数据库,所有目标消息的执行处理情况均由一个日志数据库来管理和记录,能够保证数据的最终一致性。
-
公开(公告)号:CN109634765A
公开(公告)日:2019-04-16
申请号:CN201811613790.5
申请日:2018-12-27
Applicant: 深圳金赋科技有限公司
IPC: G06F9/54
CPC classification number: G06F9/546
Abstract: 本发明涉及一种消息获取方法、电子设备和计算机存储介质。该方法从配置消息中获取目标对象,目标对象包括一个或多个元素;根据目标对象,确定替换元素;获取替换元素的实现信息;根据替换元素的实现信息确定消息获取信息,消息获取信息用于获取消息。本发明从配置消息中获取目标对象后,根据目标对象,确定替换元素;获取替换元素的实现信息;根据替换元素的实现信息确定消息获取信息,实现了消息获取流程的自由组装,降低了消息获取和其他业务功能的耦合度,并使得消息获取充满灵活性。
-
公开(公告)号:CN109614245A
公开(公告)日:2019-04-12
申请号:CN201811185360.8
申请日:2018-10-11
Applicant: 阿里巴巴集团控股有限公司
Inventor: 姜楠
IPC: G06F9/54
CPC classification number: G06F9/546 , G06F2209/547
Abstract: 本公开实施例公开了一种消息中间件的消息传递方法、装置、电子设备及存储介质。其中,所述消息中间件的消息传递方法包括:在监测到目标消息的重试事件后,获取所述目标消息的消息订阅者的运行状态;根据所述运行状态确定所述目标消息的重试策略;其中所述重试策略用于标识所述目标消息重新被发送给所述消息订阅者所要满足的条件;将所述重试策略以及所述目标消息重新放入所述消息中间件的消息队列。本公开的这种方式,可以基于消息订阅者的运行状态动态确定重试策略,并促使消息中间件基于重试策略重新传递目标消息,能够减少不必要的服务器开销。
-
公开(公告)号:CN109597694A
公开(公告)日:2019-04-09
申请号:CN201811150600.0
申请日:2018-09-29
Applicant: 阿里巴巴集团控股有限公司
IPC: G06F9/54
CPC classification number: G06F9/546
Abstract: 本说明书一个或多个实施例提供一种消息投递限流方法和装置、电子设备,所述方法包括:从消息发布者获取待投递的目标消息;响应于所述目标消息,确定是否触发了针对与所述目标消息对应的消息订阅者的消息投递限流;如果是,则基于预设的限流值对所述目标消息进行限流处理,并根据限流处理结果确定是否向所述消息订阅者投递所述目标消息;其中,所述预设的限流值为基于所述消息订阅者在单位时间段内的消息处理能力进行周期性计算得到的动态限流值。
-
公开(公告)号:CN109582456A
公开(公告)日:2019-04-05
申请号:CN201710901443.1
申请日:2017-09-28
Applicant: 北京国双科技有限公司
CPC classification number: G06F9/5038 , G06F9/546
Abstract: 本发明公开了一种报表执行方法和装置。其中,该方法包括:确定需要执行的多个报表和执行每个报表所需要的执行时长,并确定能够执行报表的多个可用队列;根据每个报表的执行时长确定每个报表所对应的队列;并行执行多个队列,使得报表得到执行。本发明解决了现有技术中执行报表方法效率低下的技术问题。
-
-
-
-
-
-
-
-
-