refactor
This commit is contained in:
@ -32,13 +32,13 @@ public:
|
|||||||
|
|
||||||
public:
|
public:
|
||||||
timeout(std::function<void()> timeout_callback,
|
timeout(std::function<void()> timeout_callback,
|
||||||
const std::chrono::system_clock::duration &duration = 10s);
|
std::chrono::system_clock::duration duration);
|
||||||
|
|
||||||
~timeout() { disable(); }
|
~timeout() { disable(); }
|
||||||
|
|
||||||
private:
|
private:
|
||||||
std::atomic<bool> timeout_killed_;
|
std::atomic<bool> timeout_killed_;
|
||||||
std::unique_ptr<std::thread> timeout_thread_;
|
std::unique_ptr<std::thread> timeout_thread_{nullptr};
|
||||||
std::mutex timeout_mutex_;
|
std::mutex timeout_mutex_;
|
||||||
std::condition_variable timeout_notify_;
|
std::condition_variable timeout_notify_;
|
||||||
|
|
||||||
|
@ -21,11 +21,9 @@
|
|||||||
*/
|
*/
|
||||||
#include "utils/timeout.hpp"
|
#include "utils/timeout.hpp"
|
||||||
|
|
||||||
#include "types/repertory.hpp"
|
|
||||||
|
|
||||||
namespace repertory {
|
namespace repertory {
|
||||||
timeout::timeout(std::function<void()> timeout_callback,
|
timeout::timeout(std::function<void()> timeout_callback,
|
||||||
const std::chrono::system_clock::duration &duration)
|
std::chrono::system_clock::duration duration)
|
||||||
: timeout_killed_(duration == 0s) {
|
: timeout_killed_(duration == 0s) {
|
||||||
if (timeout_killed_) {
|
if (timeout_killed_) {
|
||||||
return;
|
return;
|
||||||
|
Reference in New Issue
Block a user