51 results about "Distributed queuing" patented technology

The invention discloses a system for processing nonsynchronous message and a method for the system to send message and monitor processing task. The system comprises a plurality of trunked ends and a queue server end, wherein each trunked end comprises an application server and a plurality of client sides, each client side selects a queue server according to default rules, when information is sent, each trunked end serves as a sending end to select the corresponding queue server to transmit the information in a nonsynchronous way by adopting a distributed queue way; when tasks need to be processed, each trunked end serves as a monitoring end to establish a monitoring thread, setting a monitoring queue and monitor the queue server so as to process the tasks in a nonsynchronous way; the queue server end comprises a plurality of queue servers, which are used for receiving nonsynchronous information sent by each trunked end and storing tasks to be processed. According to the system and the method, the efficient and reliable transmission of the nonsynchronous information can be realized, and the system has the characteristics of strong expansibility, complete fault tolerance, convenience in use, low maintenance cost, convenient monitoring management and the like.

Distributed queue-aware power and subband allocation for delay-optimal OFDMA uplink systems with one base station, K users, and N_F independent subbands are described. For instance, the disclosed subject matter describes distributed delay-optimal power and subband allocation designs and control actions that are a function of instantaneous Channel State Information and joint Queue State Information. The disclosed details enable various refinements and modifications according to system design and tradeoff considerations.

Method and apparatus for sending and receiving data in a wireless machine to machine communication network comprising at least a gateway (2) and a plurality of nodes (4), implementing an hybrid Medium Access Control protocol to access the shared medium. In order to prevent collisions when sending data transmissions (26), nodes (4) request access to the medium with access request packets (25), and are informed by the gateway (2) if said access request packets (25) are received correctly or if a collision occurred. According to the feedback information (24) provided by the gateway (2), nodes (4) are organized in a distributed queuing system with separate queues collision resolutions and data transmissions (26). Time slots (19) with fixed length are used, divided into three separate subperiods for feedback information (24), access request packets (25) and data transmissions (26). The method and apparatus further implements channel hopping to reduce interferences from adjacent networks.

Proposed are a multi-access method and apparatus for a LoRa tag using backscatter communication. The multi-access apparatus for a LoRa tag using backscatter communication may include a contention slot unit configured to receive a signal for a contention participation request from a base station and participate in a contention according to a distributed queuing (DQ) protocol using a backscatter signal if data to be transmitted is present, an FBP unit configured to receive a result of the contention from the base station and check whether the result of the contention is a success, and a data slot unit configured to transmit sensed data to the base station using the backscatter signal if the result of the contention is a success.

The invention is a queuing message data processing method based on wireless network, comprising the following steps of: an operating hall host computer establishes relation database of logon handheld terminal numbers, reducing codes and queuing numbers; inputting operating hall number and transacted service classified data into handheld terminals; transmitting them through wireless network to the operating hall host computer to log on; the host computer distributes queuing numbers and reducing codes to handheld terminals in sequence and adding them to the database; the computer transmits updated service number, waiting number, time change and other data to each handheld terminal; inputting reducing codes into the host computer, and the computer prints queuing number bill as the basis for service transaction. A transactor can log on the host computer by handheld terminal so as to start queuing and exchanges data with the terminal through the host computer to completely learn dynamic changing queuing conditions of the operating hall.

The invention provides a method for providing a service, and the method for providing the service is applied to a server. The method for providing the service includes the following steps: receiving a service request message of a terminal; distributing queuing information to the terminal when the service request message does not carry the queuing information, recording a corresponding relationship between the queuing information and a message source address, and sending the queuing information to the terminal; verifying the corresponding relationship between the queuing information and the message source address if the service request message carries the queuing information; and determining a service priority of the terminal according to the queuing information if the terminal passes verification. According to the technical scheme of the invention, the load of the server can be reduced, and the processing speed of the server can be improved.

A method, an apparatus and an article of manufacture for providing queuing semantics in a distributed queuing service while maintaining service scalability. The method includes supporting at least one of an en-queue and a de-queue operation of one or more queued messages in a non-guaranteed order, maintaining the ordering of the one or more queued messages, and routing an en-queue operation to a persistent queue server and a de-queue operation to a cache manager in the maintained ordering of the one or more queued messages to provide queuing semantics in a distributed queuing service while maintaining service scalability.

A system for operating a robust mesh printer network with distributed queue management, comprising a print queue server that receives printer tasks via a network and maintains a print queue based on received tasks, transmits tasks via a network, and updates the print queue based on received changes and transmitted tasks, and a method for operating a robust mesh printer network with distributed queue management using a print queue server.

The invention discloses a method for allocating a distributed queue and a distributed system, wherein the method for allocating the distributed queue is applied to the distributed system and comprises the following steps of: receiving an online message of a forwarding unit; and then selecting a queue template corresponding to the type of the forwarding unit from a plurality of queue templates according to the type of the forwarding unit; and allocating the queue by utilizing the selected queue template. Through the method for allocating the distributed queue, the effects of reasonably allocating and utilizing the queue through different types of forwarding units are realized in the distributed system.

The invention discloses a distributed queuing and calling management system of a telecom business office. The distributed queuing and calling system comprises a queuing and calling management center subsystem and a business office queuing and calling subsystem, wherein the queuing and calling management center subsystem comprises a center persistent storage module used for the storage of various configuration information, business data and monitoring data of a business office network, a first queuing and calling management module used for the centralized management of queuing machine configuration and analysis and monitoring of queuing business data, and a center command processing module used for receiving and sending of processed data; the business office queuing and calling subsystem comprises a client-side command message processing module used for reporting of data and receiving of commands, a second queuing and calling management module used for the receiving of the commands to update local configuration, and a local persistent storage module used for the storage of local configuration data and intermediate data. The distributed queuing and calling management system has the stability of a stand-alone system and further has the convenience and effectiveness of a center system through the design of a loosely-coupled architecture.

The invention discloses a method and a system for performing distributed queue control on speech right in a push-to-talk over cellular (PoC) session. The system comprises a plurality of PoC user terminals participating in the PoC session and PoC servers that the PoC user terminals belong to. The method comprises the following steps that: when PoC users participating in the session belong to a plurality of PoC servers respectively, a speech request of each PoC user is saved in a local waiting queue of the PoC server that the PoC user belongs to, and the PoC servers are used to maintain respective local waiting queues respectively, and sequentially grant the speech right to the PoC users corresponding to the speech requests in the local waiting queue according to the global position identification of the speech request at the same time. The method and the system belong to the technical field of mobile communication, not only can meet the requirement of the PoC system on the waiting of the speech request, but also can overcome the disadvantages of speech right centralized control technology.

A method for automatically setting DQS (Distributed Queuing System) and DQ (Data Queuing) receiver reference voltages, the method including: using a delay string to measure a number of delay elements that match a DQS high time and a number of delay elements that match a DQS low time; wherein when the number of delay elements for the DQS low time is larger than the number of delay elements for the DQS high time, the reference voltage is decremented until the number of delay elements are equal; and wherein when the number of delay elements for the DQS low time is smaller than the number of delay elements for the DQS high time, the reference voltage is incremented until the number of delay elements are equal.

The embodiment of the invention provides a data acquisition method and device, an electronic device and a storage medium. The method comprises the following steps of: each processing module in the cluster can obtain the crawling request from the distributed queue; after crawling the data according to the obtained crawling request, the processing module can continue to package the link into a new crawling request if the link is still included in the data, and the new crawling request is delivered to the distributed queue, so that each processing module can crawl the data in parallel, and the crawling efficiency is improved.