queued_alarm.h

Go to the documentation of this file.

// Copyright 2011 Google Inc.

#ifndef PAGESPEED_KERNEL_THREAD_QUEUED_ALARM_H_
#define PAGESPEED_KERNEL_THREAD_QUEUED_ALARM_H_

#include "pagespeed/kernel/base/abstract_mutex.h"
#include "pagespeed/kernel/base/basictypes.h"
#include "pagespeed/kernel/base/function.h"
#include "pagespeed/kernel/base/scoped_ptr.h"
#include "pagespeed/kernel/thread/scheduler.h"
#include "pagespeed/kernel/thread/sequence.h"

namespace net_instaweb {

class QueuedAlarm : public Function {
 public:
  QueuedAlarm(Scheduler* scheduler,
              Sequence* sequence,
              int64 wakeup_time_us,
              Function* callback);

  void CancelAlarm();

 private:
  virtual ~QueuedAlarm();

  virtual void Run();

  void SequencePortionOfRun();

  void SequencePortionOfRunCancelled();

  scoped_ptr<AbstractMutex> mutex_;
  Scheduler* scheduler_;
  Sequence* sequence_;
  Function* callback_;
  Scheduler::Alarm* alarm_;

  bool canceled_;
  bool queued_sequence_portion_;
};

}  

#endif