We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6eb9a90 commit 71f454aCopy full SHA for 71f454a
app/src/scheduler.cc
@@ -67,9 +67,7 @@ Scheduler::Scheduler()
67
next_request_id_(0),
68
terminating_(false),
69
request_mutex_(Mutex::kModeRecursive),
70
- sleep_sem_(0) {
71
- thread_ = new Thread(WorkerThreadRoutine, this);
72
-}
+ sleep_sem_(0) {}
73
74
Scheduler::~Scheduler() {
75
CancelAllAndShutdownWorkerThread();
@@ -100,6 +98,10 @@ RequestHandle Scheduler::Schedule(callback::Callback* callback,
100
98
101
99
MutexLock lock(request_mutex_);
102
+ if (!thread_ && !terminating_) {
+ thread_ = new Thread(WorkerThreadRoutine, this);
103
+ }
104
+
105
RequestDataPtr request(
106
new RequestData(++next_request_id_, callback, delay, repeat));
107
0 commit comments