Message transmission method and apparatus, device and medium

Patent metadata

Field	Value
Publication number	US-11366707-B2
Application number	US-201916534093-A
Country	US
Kind code	B2
Filing date	Aug 7, 2019
Priority date	Aug 30, 2018
Publication date	Jun 21, 2022
Grant date	Jun 21, 2022

Abstract

The present application provides a message transmission method and apparatus, a device and a medium. The method includes: determining and outputting, by an issuing task, a data message, storing the data message in a preset storage space, and sending an issuing notification message; and reading, by a subscription task, the data message from the preset storage space according to the issuing notification message. With embodiments of the present disclosure, transmission efficiency of the data message between the issuing task and the subscription task may be improved, and source occupancy may be reduced.

First claim

What is claimed is:

1. A message transmission method, comprising:
determining and outputting, by an issuing task, a data message, storing the data message in a preset storage space, and simultaneously sending an issuing notification message to a subscription task to notify the subscription task obtaining the data message from the preset storage space directly; and
reading, by the subscription task, the data message from the preset storage space according to the issuing notification message, comprising: obtaining, by the subscription task, a timestamp of the data message from the issuing notification message, wherein the timestamp is configured to fuse the data messages to determine an associated reference of data message from different issuing tasks within a preset time period, so as to cause a function module preventing from obtaining a false execution result based on false fusion information.

2. The method according to claim 1 , wherein, sending, by the issuing task, the issuing notification message comprises:
sending, by the issuing task, the issuing notification message to a program interface of the subscription task in at least one of a broadcast way, a multicast way and a unicast way.

3. The method according to claim 2 , before sending, by the issuing task, the issuing notification message to the program interface of the subscription task in the multicast way, further comprising at least one of:
determining, by the issuing task, at least two subscription tasks corresponding to the issuing task to form a multicast group of the issuing notification message according to a task topology relation; and
forming, by the issuing task, a multicast group corresponding to the issuing notification message according to at least one of a task networking relation of a physical layer and a task networking relation of an operation system layer.

4. The method according to claim 1 , wherein, reading, by the subscription task, the data message from the preset storage space according to the issuing notification message comprises:
obtaining, by the subscription task, a message identifier in the issuing notification message when the subscription task receives the issuing notification message; and
reading, by the subscription task, the data message from the preset storage space in response to the message identifier in the issuing notification message being matched with a message identifier in a preset subscribed message of the subscription task.

5. The method according to claim 1 , wherein, reading, by the subscription task, the data message from the preset storage space according to the issuing notification message comprises:
reading, by the subscription task, the data message from a storage unit of which a storage address is matched with a message storage address in the issuing notification message according to the message storage address.

6. The method according to claim 1 , wherein, reading, by the subscription task, the data message from the preset storage space according to the issuing notification message comprises:
reading, by the subscription task, the data message from the preset storage space, and storing the data message in a message queue based on the timestamp, in which, the subscription task processes the data message according to a sequence of messages in the message queue.

7. The method according to claim 1 , wherein, the subscription task and the issuing task are executed by threads respectively, and the preset storage space is a shared memory space.

8. The method according to claim 1 , wherein, the subscription task and the issuing task are processing tasks in an automatic vehicle system; and the automatic vehicle system comprises at least one of: at least one image sensing task, a laser point cloud sensing task, a planning task and a driving task.

9. The method according to claim 2 , wherein, the subscription task and the issuing task are executed by threads respectively, the preset storage space is a shared memory space, the subscription task and the issuing task are processing tasks in an automatic vehicle system; and the automatic vehicle system comprises at least one of: at least one image sensing task, a laser point cloud sensing task, a planning task and a driving task.

10. The method according to claim 3 , wherein, the subscription task and the issuing task are executed by threads respectively, the preset storage space is a shared memory space, the subscription task and the issuing task are processing tasks in an automatic vehicle system; and the automatic vehicle system comprises at least one of: at least one image sensing task, a laser point cloud sensing task, a planning task and a driving task.

11. The method according to claim 4 , wherein, the subscription task and the issuing task are executed by threads respectively, the preset storage space is a shared memory space, the subscription task and the issuing task are processing tasks in an automatic vehicle system; and the automatic vehicle system comprises at least one of: at least one image sensing task, a laser point cloud sensing task, a planning task and a driving task.

12. The method according to claim 5 , wherein, the subscription task and the issuing task are executed by threads respectively, the preset storage space is a shared memory space, the subscription task and the issuing task are processing tasks in an automatic vehicle system; and the automatic vehicle system comprises at least one of: at least one image sensing task, a laser point cloud sensing task, a planning task and a driving task.

13. The method according to claim 6 , wherein, the subscription task and the issuing task are executed by threads respectively, the preset storage space is a shared memory space, the subscription task and the issuing task are processing tasks in an automatic vehicle system; and the automatic vehicle system comprises at least one of: at least one image sensing task, a laser point cloud sensing task, a planning task and a driving task.

14. A device, comprising:
one or more processors;
a storage device, configured to store one or more programs;
wherein when the one or more programs are executed by the one or more processors, the one or more processors are caused to implement a message transmission method, and the method comprises: determining and outputting, by an issuing task, a data message, storing the data message in a preset storage space, and simultaneously sending an issuing notification message to a subscription task to notify the subscription task obtaining the data message from the preset storage space directly; and reading, by the subscription task, the data message from the preset storage space according to the issuing notification message, comprising: obtaining, by the subscription task, a timestamp of the data message from the issuing notification message, wherein the timestamp is configured to fuse the data messages to determine an associated reference of data message from different issuing tasks within a preset time period, so as to cause a function module preventing from obtaining a false execution result based on false fusion information.

15. A non-statutory computer readable storage medium having a computer program stored thereon, wherein, the computer program is configured to be executed to implement a message transmission method, and the method comprises: determining and outputting, by an issuing task, a data message, storing the data message in a preset storage space, and simultaneously sending an issuing notification message to a subscription task to notify the subscription task obtaining the data message from the preset storage space di

Assignees

• Baidu online network technology beijing co ltd
• Apollo Intelligent Driving Tech Beijing Co Ltd

Inventors

• Xia Liming
• Chen Zhuo
• Ni Zhongjun
• Bao Wanyu
• Peng Ronggui
• Dang Yuedong

Classifications

• G06F9/546 Primary

  Message passing systems or structures, e.g. queues · CPC title

• G06F9/542

  Event management; Broadcasting; Multicasting; Notifications · CPC title

• G06F3/061

  Improving I/O performance · CPC title

• G06F3/0655 Primary

  Vertical data movement, i.e. input-output transfer; data movement between one or more hosts and one or more storage devices · CPC title

• G06F9/544 Primary

  Buffers; Shared memory; Pipes · CPC title