refactor, add TODO.

lichao

2021-04-13 3e191ac65bd65f678e9a344163f74d181726f6bd

 src/timed_queue.h

@@ -24,23 +24,37 @@
#include <string>

template <class Data, class ClockType = std::chrono::steady_clock>
class TimedQueue
class TimedData
{
public:
   typedef ClockType Clock;
   typedef typename Clock::time_point TimePoint;
   typedef typename Clock::duration Duration;

private:
   struct Record {
      TimePoint expire_;
      Data data_;
      Record(const TimePoint &expire, const Data &data) :
   TimedData(const TimePoint &expire, const Data &data) :
          expire_(expire), data_(data) {}
      Record(const TimePoint &expire, Data &&data) :
   TimedData(const TimePoint &expire, Data &&data) :
          expire_(expire), data_(std::move(data)) {}
      bool Expired() { return Clock::now() > expire_; }
   Data &data() { return data_; }
   Data const &data() const { return data_; }

private:
   TimePoint expire_;
   Data data_;
   };

template <class Data, class ClockType = std::chrono::steady_clock>
class TimedQueue
{
   typedef TimedData<Data, ClockType> Record;

public:
   typedef typename Record::Clock Clock;
   typedef typename Record::TimePoint TimePoint;
   typedef typename Record::Duration Duration;

private:
   typedef std::list<Record> Queue;
   Synced<Queue> queue_;

@@ -62,7 +76,7 @@
         do {
            if (it->Expired()) {
               it = q.erase(it);
            } else if (func(it->data_)) {
            } else if (func(it->data())) {
               it = q.erase(it);
            } else {
               ++it;