Calculer le nombre de messages par seconde dans une fenêtre mobile?

C'est plus facile est gérée par un tampon cyclique.

Un tampon cyclique a un nombre fixe d'éléments, et un pointeur vers elle. Vous pouvez ajouter un élément de la mémoire tampon, et quand vous le faites, vous incrémenter le pointeur sur l'élément suivant. Si vous avez passé le tampon de longueur fixe de commencer depuis le début. C'est un espace et le temps moyen efficace de stocker des "dernier N" éléments.

Maintenant, dans votre cas, vous pouvez avoir un tampon cyclique de 1 000 compteurs, chacun comptant le nombre de messages pendant une milliseconde. L'ajout de tous les 1 000 compteurs vous donne le nombre total au cours de la dernière seconde. Bien sûr, vous pouvez optimiser la production de rapports partie par progressivement mise à jour le comte, c'est à dire déduire de l'compter le nombre d'écraser lorsque vous insérez puis ajouter le nouveau numéro.

Vous pouvez alors avoir une autre tampon cyclique qui dispose de 60 emplacements et compte le nombre total de messages dans l'ensemble, les secondes; une fois par seconde, vous prenez le nombre total de l'ordre de la milliseconde tampon et écrire le comte le tampon ayant une résolution de secondes, etc.

Ici C comme pseudo:

int msecbuf[1000]; //initialized with zeroes
int secbuf[60]; //ditto
int msecptr = 0, secptr = 0;
int count = 0;
int msec_total_ctr = 0;
void msg_received() { count++; }
void every_msec() {
  msec_total_ctr -= msecbuf[msecptr];
  msecbuf[msecptr] = count;
  msec_total_ctr += msecbuf[msecptr];
  count = 0;
  msecptr = (msecptr + 1) % 1000;
}
void every_sec() {
  secbuf[secptr] = msec_total_ctr;
  secptr = (secptr + 1) % 60;
}

Pour la dernière millisecord, gardez le comte. Lorsque le millisecord tranche va à la prochaine, réinitialiser le comte et ajouter le comte à une milliseconde de roulement tableau tampon. Si vous gardez ce cumulative, vous pouvez extraire le nombre de messages /seconde avec un montant fixe de la mémoire.

Lors de l'une de 0,1 seconde tranche (ou une autre petite valeur de près de 1 minute) est fait, la somme jusqu'à la dernière 0,1*1000 articles des rolling tableau tampon et le placer que dans le prochain roulement de la mémoire tampon. De cette façon, vous kan garder le millisecord de roulement de la mémoire tampon de petite taille (1000 articles pour 1s max de recherche) et de la mémoire tampon pour la recherche de la minute aussi (600 points).

Vous pouvez faire la prochaine astuce pour l'ensemble du procès-verbal de 0,1 minutes d'intervalle. Toutes les questions posées peuvent être interrogé par la somme (ou lors de l'utilisation cumulée , soustrayant deux valeurs) quelques entiers.

Le seul inconvénient est que le dernier de la sec de la valeur wil changer tous les ms et la valeur de minute seulement tous les 0,1 secand la valeur de l'heure (et dérivés, à l' % dans la dernière 1/2 heure) tous les 0,1 minute. Mais au moins vous gardez votre utilisation de la mémoire à la baie.

J'ai pensé à maintenir une file d'attente de tous les messages, à la recherche pour le dernier message datant de plus d'une seconde, et déduire le comte de l'index. Cependant, il semble que ce serait trop lent, et mange beaucoup de mémoire.

Une meilleure idée serait de maintenir une liste de messages, l'ajout de nouveaux messages à la tête (avec un timestamp), et sautant de la queue de leur expiration. Ou même pas de pop - gardez juste un pointeur vers le message le plus ancien qui est arrivé dans les délais voulus, et avance vers la tête lorsque que le message arrive à expiration (ce qui vous permet de garder une trace de multiplier les délais avec une liste).

On peut calculer le comte, si nécessaire, en marche de la queue à la tête, ou tout simplement stocker le comte séparément, en augmentant à chaque fois que vous ajoutez une valeur à la tête, et décrémenter à chaque fois que vous l'avance la queue.