|
|
@ -45,6 +45,7 @@ end |
|
|
|
function _M.getInstance(self) |
|
|
|
function _M.getInstance(self) |
|
|
|
if rawget(self, "instance") == nil then |
|
|
|
if rawget(self, "instance") == nil then |
|
|
|
rawset(self, "instance", self.new()) |
|
|
|
rawset(self, "instance", self.new()) |
|
|
|
|
|
|
|
self.cron() |
|
|
|
end |
|
|
|
end |
|
|
|
assert(self.instance ~= nil) |
|
|
|
assert(self.instance ~= nil) |
|
|
|
return self.instance |
|
|
|
return self.instance |
|
|
@ -474,8 +475,7 @@ function _M.cron(self) |
|
|
|
ngx.update_time() |
|
|
|
ngx.update_time() |
|
|
|
-- self:D("PID:"..tostring(ngx.worker.id()).."--【"..tostring(llen).."】, elapsed: " .. tostring(ngx.now() - begin)) |
|
|
|
-- self:D("PID:"..tostring(ngx.worker.id()).."--【"..tostring(llen).."】, elapsed: " .. tostring(ngx.now() - begin)) |
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
ngx.timer.every(0.5, timer_every_get_data) |
|
|
|
ngx.timer.every(1, timer_every_get_data) |
|
|
|
|
|
|
|
end |
|
|
|
end |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|