taskrunner.h

本人收集整理的一份c/c++跨平台网络库

#ifndef UTILS_BASE_TASKRUNNER_H_
#define UTILS_BASE_TASKRUNNER_H_

#include <vector>

#include "sigslot.h"
#include "task.h"

namespace utils_base {

class Task;

const int64 kSecToMsec = 1000;
const int64 kMsecTo100ns = 10000;
const int64 kSecTo100ns = kSecToMsec * kMsecTo100ns;

class TaskRunner : public Task, public sigslot::has_slots<> {
 public:
  TaskRunner();
  virtual ~TaskRunner();

  virtual void WakeTasks() = 0;

  // This method returns the current time in 100ns units since 1/1/1601.  This
  // Is the GetSystemTimeAsFileTime method on windows.
  virtual int64 CurrentTime() = 0 ;

  void StartTask(Task *task);
  void RunTasks();
  void PollTasks();

  void UpdateTaskTimeout(Task *task);

  // dummy state machine - never run.
  virtual int ProcessStart() { return STATE_DONE; }

 private:
  std::vector<Task *> tasks_;
  Task *next_timeout_task_;
  bool tasks_running_;

  void RecalcNextTimeout(Task *exclude_task);
};

} // namespace utils_base

#endif  // UTILS_BASE_TASKRUNNER_H_