US 11,863,461 B2
Data processing method, data processing apparatus, electronic device, storage medium, and program product
Yangshu Shen, Beijing (CN); and Yaolong Zhu, Beijing (CN)
Assigned to LYNXI TECHNOLOGIES CO., LTD., Beijing (CN)
Appl. No. 17/778,929
Filed by LYNXI TECHNOLOGIES CO., LTD., Beijing (CN)
PCT Filed Dec. 9, 2020, PCT No. PCT/CN2020/134921
§ 371(c)(1), (2) Date May 23, 2022,
PCT Pub. No. WO2021/115326, PCT Pub. Date Jun. 17, 2021.
Claims priority of application No. 201911252455.1 (CN), filed on Dec. 9, 2019; and application No. 201911252471.0 (CN), filed on Dec. 9, 2019.
Prior Publication US 2022/0417169 A1, Dec. 29, 2022
Int. Cl. H04L 47/6275 (2022.01); H04L 49/109 (2022.01); H04L 47/62 (2022.01)
CPC H04L 47/6275 (2013.01) [H04L 47/6235 (2013.01); H04L 49/109 (2013.01)] 19 Claims
OG exemplary drawing
 
1. A data processing method which, in each processing cycle, comprises:
determining a plurality of candidate data pieces, wherein the candidate data pieces are provided from corresponding data sources; and
determining a target data piece based on priorities of the data sources corresponding to the plurality of candidate data pieces in a current cycle,
wherein a same data source has different priorities in different processing cycles, and priority sequence numbers of a same data source in different processing cycles satisfy a nonlinear relationship, and
wherein
in one processing cycle, the operation of determining the target data piece based on the priorities of the data sources corresponding to the plurality of candidate data pieces in the current cycle comprises:
determining the number of data sources in an Nth level arbitration, wherein N is a natural number and 1≤N≤M, and M is the total number of arbitration levels in the current processing cycle;
generating codes from the number of data sources in the Nth level arbitration in a set encoding mode; and
assigning all the generated codes to all data sources in the Nth level arbitration according to a set priority order,
and in each processing cycle, the operation of determining the target data piece based on the priorities of the data sources corresponding to the plurality of candidate data pieces in the current cycle further comprises:
generating a target code for a data source corresponding to each candidate data piece according to the generated codes;
arbitrating, according to the target code and a priority order corresponding to the target code, the data source corresponding to each candidate data piece to determine the target data piece; and
updating, according to an arbitration result, a priority order of all data sources at each level of arbitration.