/*
- * Copyright 2015 Facebook, Inc.
+ * Copyright 2017 Facebook, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
TimePoint now() override { return now_; }
+ /// Flush the function queue. Destroys all stored functions without
+ /// executing them. Returns number of removed functions.
+ std::size_t clear() {
+ std::queue<Func> funcs;
+ std::priority_queue<ScheduledFunc> scheduled_funcs;
+
+ {
+ std::lock_guard<std::mutex> lock(lock_);
+ funcs_.swap(funcs);
+ scheduledFuncs_.swap(scheduled_funcs);
+ }
+
+ return funcs.size() + scheduled_funcs.size();
+ }
+
private:
std::mutex lock_;
std::queue<Func> funcs_;
struct ScheduledFunc {
TimePoint time;
size_t ordinal;
- Func func;
+ Func mutable func;
ScheduledFunc(TimePoint const& t, Func&& f)
: time(t), func(std::move(f))
return ordinal < b.ordinal;
return time < b.time;
}
+
+ Func&& moveOutFunc() const {
+ return std::move(func);
+ }
};
std::priority_queue<ScheduledFunc> scheduledFuncs_;
- TimePoint now_ = now_.min();
+ TimePoint now_ = TimePoint::min();
};
}