--[[
	deque 为了减少锁竞争，尽量保证 a服务 push；b服务 pop
]]
local skynet = require "skynet"
local deque = require "deque"

local CMD = {}
local factory

local PRE_FEED_COUNT = 5
local dead = 0
-- agent死亡，通知poold补充，当累计到5个agent时，马上生成5个agent放入poold中
-- 当然这里也可以写得更复杂，参考redis落地规则
function CMD.feed()
	dead = dead + 1
	if dead == PRE_FEED_COUNT then
		dead = 0
		for i=1, PRE_FEED_COUNT do
			factory:push(skynet.newservice("agent"))
		end
	end
end

-- 系统启动，生成count个agent放入双端队列中
function CMD.start(count)
	factory, addr = deque.new(count)

	for i=1, count do
		factory:push(skynet.newservice("agent"))
	end

	return addr
end

local function __init__()
	skynet.dispatch("lua", function (_, _, command, ...)
		local f = CMD[command]
		if command == "start" then
			skynet.ret(skynet.pack(f(...)))
			return
		end
		f(...)
	end)
end

skynet.start(__init__)