Я пытаюсь смоделировать систему следующим образом:
Прибытия генерируются в соответствии с заранее определенным расписанием и имеют известное время обработки, предоставляемое кадром данных. В начале симуляции имеется единственный сервер с мощностью, равной min_daemons. Пока все просто, но с nxt все сложнее: эта мощность может меняться на интервале [min_daemons, max_daemons] на протяжении всей симуляции по следующему алгоритму:
Если в любой момент моделирования длина очереди достигает или превышает значение incr_count и остается на этом уровне или выше для incr_delay, то к основному серверу добавляется дополнительная единица емкости. Это может произойти в любой момент, при условии, что мощность никогда не превышает max_daemons.
Обратное также верно. Если в любой момент длина очереди меньше, чем decr_count, и остается на уровне или ниже этого уровня для decr_delay, единица емкости удаляется, возможно, до уровня min_daemons.
Я создал траекторию для всех прибытий, которая разветвляется, когда выполняются указанные выше условия изменения мощности сервера. Проблема в том, что изменения пропускной способности всегда связаны с событием прибытия. Чего я действительно хочу, так это процесса, независимого от траектории прибытия, который постоянно отслеживает длину очереди и вносит соответствующие изменения в пропускную способность.
В качестве альтернативы я рассматривал вариант выполнения этого с помощью какого-то фиктивного процесса прибытия, скажем, каждую секунду моделирования, но я не был уверен, смогу ли я предотвратить конкуренцию фиктивных прибытий с реальными поступлениями за пропускную способность сервера.
#instantiate simulation environment
env <- simmer("queues") %>% add_resource("daemon",1) %>% add_global("incr_start",99999) %>% add_global("decr_start",99999)
run <- trajectory() %>%
branch(option = function() if (get_queue_count(env,"daemon") >= incr_count) {1}
else if (get_queue_count(env,"daemon") <= decr_count) {2}
else {3}
,
continue = c(T, T, T)
,
trajectory("increment?")
%>% branch(option = function() if (now(env) - get_global(env,"incr_start") >= incr_delay
& get_capacity(env,"daemon") < max_daemons) {1}
else if (get_global(env,"incr_start")==99999) {2}
else {3}
,
continue = c(T, T, T)
,
trajectory("increment")
%>% log_(function () {paste("Queue size is: ",get_queue_count(env,"daemon"))})
%>% log_(function ()
{paste("Queue has exceeded count for ",now(env)-get_global(env,"incr_start")," seconds.")})
%>% set_capacity(resource = "daemon", value = 1, mod="+")
,
trajectory("update incr start")
%>% set_global("incr_start",now(env))
%>% log_("Queue count is now above increment count. Starting increment timer.")
,
trajectory("do nothing")
%>% log_("Did not meet increment criteria. Doing nothing.")
)
,
trajectory("decrement?")
%>% branch(option = function() if (now(env) - get_global(env,"decr_start") >= decr_delay
& get_capacity(env,"daemon") > min_daemons) {1}
else if (get_global(env,"decr_start")==99999) {2}
else {3}
,
continue = c(T, T, T)
,
trajectory("decrement")
%>% log_(function () {paste("Queue size is: ",get_queue_count(env,"daemon"))})
%>% log_(function ()
{paste("Queue has been less than count for ",now(env)-get_global(env,"incr_start")," seconds.")})
%>% set_capacity(resource = "daemon", value = -1, mod="+")
,
trajectory("update decr start")
%>% set_global("decr_start",now(env))
%>% log_("Queue count is now below decrement count. Starting decrement timer.")
,
trajectory("do nothing")
%>% log_("Did not meet decrement criteria. Doing nothing.")
)
,
trajectory("reset_timer")
%>% log_("Did not meet criteria to increment or decrement. Resetting timers.")
%>% set_global("decr_start", values = 99999)
%>% set_global("decr_start", values = 99999)
) %>%
seize("daemon") %>%
log_("Now running") %>%
log_(function () {paste(get_queue_count(env,"daemon")," runs in the queue.")}) %>%
timeout_from_attribute("service") %>%
release("daemon") %>%
log_("Run complete")
env %>%
add_dataframe("run", run, arr,time="absolute") %>%
run(200)
Мне нужно выполнить дополнительную отладку, чтобы убедиться, что симуляция работает так, как я задумал, но я полностью понимаю, что эта модель неверна. Я могу надеяться, что дизайн не слишком скомпрометирует его достоверность, но я также хочу получить обратную связь о том, как я могу создать что-то более близкое к реальной жизни.
