0

我正在尝试使用累加器来找出每秒给定活动的统计信息。以下是我要计算的两个统计数据

  • 活动被触发的次数

  • 活动触发的总权重之和。

    为了实现这一目标，我假设了 10 毫秒的粒度并考虑了 100 个桶（每秒）。

  • 每当有事件发生时，Activity 线程就会插入累加器

  • 空活动线程每 10 毫秒唤醒一次，以在权重中插入 0。

下面的伪代码

#include <boost/accumulators/accumulators.hpp>
#include <boost/accumulators/statistics/stats.hpp>
#include <boost/accumulators/statistics/rolling_count.hpp>
#include <boost/accumulators/statistics/rolling_sum.hpp>

using namespace boost::accumulators;

#define MAX_WEIGHT 100
#define MAX_ACIVITY 10

accumulator_set<double, features<tag::rolling_count, tag::rolling_sum> > acc(tag::rolling_window::window_size = 100);

void null_run()//invoked every 10 msecs 
{
  //mutex protected
  acc(0);
}

void activity_triggered(int weight) // triggered by an external event
{
  //mutex protected
  acc(weight);
  if (checkStatus() == false)
  {
    printf("Max quantity per sec reached stop ");
    exit()
  }
}


bool checkStatus()
{
   int weightPerSec  = rolling_sum(acc);
   //here I would like to get the count only if non zero may be rolling_count_non_zero()??
   int acitivitiesPersec = rolling_count(acc); 
   
   if (weightPerSec > MAX_WEIGHT)
     return false;
   if (acitivitiesPersec > MAX_ACTIVITY)
     return false;
   return true;
}

使用上述技术，我能够实现在最后一秒输入的重量，但是如何使用增压蓄能器在最后一秒内触发活动的次数？

4

1 回答 1

2

当然rolling_count_non_zero听起来像是你想要的一个合适的名字（尽管它可能更通用一些，也许rolling_count_if？）。

Boost.accumulators 用户指南描述了如何编写自己的累加器、特性和提取器，只需按照该描述，以下似乎就可以工作：

namespace boost { namespace accumulators { namespace impl {
    template<typename Sample>
    struct rolling_count_non_zero : accumulator_base
    {
        typedef std::size_t result_type;
        rolling_count_non_zero(dont_care) : cnt_() {}
        template<typename Args>
        void operator ()(Args const &args)
        {
            if(args[sample] != 0)
                ++cnt_;
            if(is_rolling_window_plus1_full(args)
               && rolling_window_plus1(args).front() != 0 )
                --cnt_;
        }
        template<typename Args>
        result_type result(Args const &args) const { return cnt_; }
    private:
        std::size_t cnt_;
    };

} namespace tag {
    struct rolling_count_non_zero : depends_on< rolling_window_plus1 >
    {
        typedef accumulators::impl::rolling_count_non_zero< mpl::_1 > impl;
    };
} namespace extract {
    extractor<tag::rolling_count_non_zero> const rolling_count_non_zero = {};
}
using extract::rolling_count_non_zero;
}}

现场演示：http ://coliru.stacked-crooked.com/a/bc4bea090690f26d

于 2013-11-07T21:59:36.983 回答