Method, device, and system for information processing based on distributed buses
First Claim
1. A method for information processing based on distributed buses, the method comprising:
- at a server having one or more processors and memory storing programs executed by the one or more processors,receiving a plurality of connection requests from a plurality of client terminals respectively;
establishing connection between the server and the plurality of client terminals respectively in response to the plurality of connection requests;
establishing respective communication sessions between one or more communication channels of the server and one or more client terminals of the plurality of client terminals that are connected to the server;
receiving one or more processing request packets from the one or more client terminals that have respective communication sessions established with the server;
entering the one or more processing request packets into a single input information queue, wherein the one or more processing request packets are ranked according to time of entering of respective processing request packets;
determining a number of idle information processing threads;
selecting, from the front of the input information queue, a number of processing request packets that is equal to the number of idle information processing threads;
using the idle information processing threads to process the selected processing request packets to obtain response data packets respectively;
storing the response data packets obtained from the information processing threads in a number of output information queues respectively, wherein the number of output information queues is equal to the number of information processing threads, and wherein each information processing thread is associated with and configured to use a respective output information queue to store response data packets generated by the corresponding information processing thread; and
transmitting the response data packets within a respective output information queue to a corresponding client terminal.
1 Assignment
0 Petitions
Accused Products
Abstract
The present application discloses methods, devices, and systems for information processing based on distributed buses. A server may receive processing request packets from one or more client terminals and enter the processing request packets into a single input information queue. After determining a number of idle information processing threads, the server may use the idle information processing threads to process the selected processing request packets to obtain response data packets. Each information processing thread is configured to use a respective output information queue to store response data packets generated by the information processing thread. The server may then transmit the response data packets within a respective output information queue to a corresponding client terminal. The current method, as well as the devices and systems associated with the method, may be used to facilitate information processing, improve efficiency, and prevent excessive burden and data loss.
4 Citations
20 Claims
-
1. A method for information processing based on distributed buses, the method comprising:
at a server having one or more processors and memory storing programs executed by the one or more processors, receiving a plurality of connection requests from a plurality of client terminals respectively; establishing connection between the server and the plurality of client terminals respectively in response to the plurality of connection requests; establishing respective communication sessions between one or more communication channels of the server and one or more client terminals of the plurality of client terminals that are connected to the server; receiving one or more processing request packets from the one or more client terminals that have respective communication sessions established with the server; entering the one or more processing request packets into a single input information queue, wherein the one or more processing request packets are ranked according to time of entering of respective processing request packets; determining a number of idle information processing threads; selecting, from the front of the input information queue, a number of processing request packets that is equal to the number of idle information processing threads; using the idle information processing threads to process the selected processing request packets to obtain response data packets respectively; storing the response data packets obtained from the information processing threads in a number of output information queues respectively, wherein the number of output information queues is equal to the number of information processing threads, and wherein each information processing thread is associated with and configured to use a respective output information queue to store response data packets generated by the corresponding information processing thread; and transmitting the response data packets within a respective output information queue to a corresponding client terminal. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
11. A computer system based on distributed buses, the computer system comprising:
-
one or more processors; memory; and one or more programs stored in the memory and configured for execution by the one or more processors, the one or more programs include instructions for; receiving a plurality of connection requests from a plurality of client terminals respectively; establishing connection between the server and the plurality of client terminals respectively in response to the plurality of requests for connection; establishing respective communication sessions between one or more communication channels of the server and one or more client terminals of the plurality of client terminals that are connected to the server; receiving one or more processing request packets from the one or more client terminals that have respective communication sessions established with the server; entering the one or more processing request packets into a single input information queue, wherein the one or more processing request packets are ranked according to time of entering of respective processing request packets; determining a number of idle information processing threads; selecting, from the front of the input information queue, a number of processing request packets that is equal to the number of idle information processing threads; using the idle information processing threads to process the selected processing request packets to obtain response data packets respectively, storing the response data packets obtained from the information processing threads in a number of output information queues respectively, wherein the number of output information queues is equal to the number of information processing threads, and wherein each information processing thread is associated with and configured to use a respective output information queue to store response data packets generated by the corresponding information processing thread; and transmitting the response data packets within a respective output information queue to a corresponding client terminal. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19)
-
-
20. A non-transitory computer readable storage medium having stored therein instructions, which, when executed by a computer system, cause the computer system to:
-
receive a plurality of connection requests from a plurality of client terminals respectively; establish connection between the server and the plurality of client terminals respectively in response to the plurality of requests for connection; establish respective communication sessions between one or more communication channels of the server and one or more client terminals of the plurality of client terminals that are connected to the server; receive one or more processing request packets from the one or more client terminals that have respective communication sessions established with the server; enter the one or more processing request packets into a single input information queue, wherein the one or more processing request packets are ranked according to time of entering of respective processing request packets; determine a number of idle information processing threads; select, from the front of the input information queue, a number of processing request packets that is equal to the number of idle information processing threads; and use the idle information processing threads to process the selected processing request packets to obtain response data packets respectively; store the response data packets obtained from the information processing threads in a number of output information queues respectively, wherein the number of output information queues is equal to the number of information processing threads, and wherein each information processing thread is associated with and configured to use a respective output information queue to store response data packets generated by the corresponding information processing thread; and transmit the response data packets within a respective output information queue to a corresponding client terminal.
-
Specification