Articles of queue

RabbitMQ – Ordre de livraison des messages

Je dois choisir un nouveau courtier Queue pour mon nouveau projet. Cette fois, j’ai besoin d’une queue évolutive qui prend en charge pub / sub, et il est essentiel de conserver l’ordre des messages. J’ai lu le commentaire d’Alexis: Il écrit: “En effet, nous pensons que RabbitMQ fournit des commandes plus fortes que Kafka” J’ai […]

Existe-t-il une implémentation PriorityQueue avec une capacité fixe et un comparateur personnalisé?

Questions connexes: Java PriorityQueue à taille fixe Comment utiliser un PriorityQueue? obtenir les index des n plus petits éléments d’un tableau Scala: Est-il possible d’utiliser PriorityQueue comme je le ferais en Java? J’ai un très grand dataset (plus de 5 millions d’éléments) et je dois en extraire N plus gros éléments. La manière la plus […]

Une queue prioritaire générique pour Python

Je dois utiliser une queue prioritaire dans mon code Python. En cherchant quelque chose d’efficacité, je suis tombé sur heapq . Il semble bon, mais semble être spécifié uniquement pour les entiers. Je suppose que cela fonctionne avec tous les objects qui ont des opérateurs de comparaison, mais cela ne spécifie pas les opérateurs de […]

Streaming log (txt) viewer

Quelqu’un dans la connaissance d’un lecteur (ou Notepad ++ plugin) qui peut lire les fichiers txt en streaming? J’aimerais voir par exemple les 10 dernières lignes d’un fichier txt qui est ajouté en continu.

File d’attente à grande échelle et à faible latence

Je repense un peu aux jeux multijoueurs à grande échelle à l’ère des applications Facebook et du cloud computing. Supposons que je construise quelque chose au-dessus des protocoles ouverts existants, et que je veuille servir 1 000 000 de joueurs simultanés, simplement pour résoudre le problème. Supposons que chaque joueur dispose d’une queue de messages […]

TThreadedQueue pas capable de plusieurs consommateurs?

Essayer d’utiliser le TThreadedQueue (Generics.Collections) dans un schéma de consommateur multiple à producteur unique. (Delphi-XE). L’idée est de pousser des objects dans une queue et de laisser plusieurs threads de travail drainer la queue. Cela ne fonctionne pas comme prévu, cependant. Lorsque plusieurs threads de travail appellent PopItem, les violations d’access sont renvoyées à partir […]

File d’attente C ++ 11 adaptée aux threads

Un projet sur lequel je travaille utilise plusieurs threads pour travailler sur une collection de fichiers. Chaque thread peut append des fichiers à la liste des fichiers à traiter. J’ai donc assemblé (ce que je pensais) une queue adaptée aux threads. Les parties pertinentes suivent: // qMutex is a std::mutex intended to guard the queue […]

Comment itérer sur une priority_queue?

Puis-je parcourir une queue standard ou standard dans c ++ avec un iterator (comme un vector )? Je ne veux pas utiliser de pop car cela entraîne la mise en queue de ma queue. Merci pour toute aide

Demander des requêtes ajax en utilisant jQuery.queue ()

J’utilise jQuery.queue () pour la première fois et je ne l’ai pas bien compris. Quelqu’un pourrait-il indiquer ce que je fais mal? En regardant dans Firebug, je vois toujours mes requêtes POST se déclencher en même temps – alors je me demande si j’appelle dequeue () au mauvais endroit. Aussi, comment puis-je obtenir la longueur […]

Fil de discussion Producteur / Consommateur utilisant une queue

Je voudrais créer une sorte d’application de filetage Producer/Consumer . Mais je ne suis pas sûr de la meilleure façon de mettre en place une queue entre les deux. Donc, j’en ai deux avec deux idées (les deux pouvant être totalement erronées). Je voudrais savoir ce qui serait mieux et si les deux sucent alors […]