215 похожих чатов

Парни, помогите разобраться с транзакциями и конкурентностью. Допутим есть функция типа

такой:
-- Get Campaign TIC
exports.make_campaign_tic = function(campaign_id, first_tic)
local campaign = campaigns:get{campaign_id }
if (campaign ~= nil) then
if (campaign[2] == true) then
return 'tic'
else
-- Set running (3) state for first tic and keep existed state for
-- all another tics
local campaign_state = campaign[3]
if (first_tic) then
campaign_state = 3
end
-- Imediatelly set "ticking" state, before agents counts starts
campaign = campaigns:update(campaign_id,
{{'=', 2, true}, {'=', 3, campaign_state}})
-- Count all agents states
local online = 0
local lazy = 0
local available = 0
local busy = 0
for _, rec in sip_users.index.campaign_id_index:pairs(campaign_id) do
if (rec[6] ~= 0) then
online = online + 1
if (rec[6] == 1) then
lazy = lazy + 1
elseif (rec[6] == 2 and rec[11] == false) then
available = available + 1
end

if (rec[11] == true) then
busy = busy + 1
end
end
end
campaign = campaigns:update(campaign_id,
{
{'=', 2, true},
{'=', 3, campaign_state},
{'=', 5, online},
{'=', 6, lazy},
{'=', 7, available},
{'=', 8, busy }
})
return campaign
end
else
return nil
end
end
Суть вопроса, когда я ее вызываю извне, transaction processor ее всю выполняет в одной транзакции или нет? То есть могут ли другие запросы выпоняться с ней параллельно, могут ли они читать данные?
Мой затык получается в атомарности, я хочу понять возможна ли ситуация, когда я что-то делаю в функции, а другой запрос процитает старые данные, которые эта функция должна обновить.

1 ответов

8 просмотров

Memtx? Если да, то memtx переключает файберы только при записи, если запись идет несколько раз, то нужно использовать box.begin/box.commit

Похожие вопросы

Обсуждают сегодня

Какой-то там пердун в 90-х решил, что есть какая-то разная типизация. Кого вообще это волнует?
КТ315
49
Подскажите, а есть vault lite или ченить такое?) А то нужен вольт для похода в вольт, но весит он ~500 мб) как-то многовато для парочки запросов ))
Alexandr Orloff
17
void terminal_scroll() { memmove(terminal_buffer, terminal_buffer + VGA_WIDTH, buffer_size - VGA_WIDTH); memset(terminal_buffer + buffer_size - VGA_WIDTH, 0, VGA_WIDTH); ...
Егор
47
Всем привет! Подскажите, пожалуйста, в чем ошибка? Настраиваю подключение к MySQL. Либы лежат рядом с exe. Все как по "учебнику"
Евгений
16
А можете как-то проверить меня по знаниям по ассемблеру?
A A
132
Здравствуйте! У меня появилась возможность купить книгу "Изучай Haskell во имя добра!". Но я где-то слышал, что эта книга устарела. Насколько это правда??
E
22
Здравствуйте! Я вот на stepic решаю задачи на хаскеле https://stepik.org/lesson/8443/step/8?unit=1578 мой код import Data.List (isInfixOf) removing :: String -> [String] ->...
E
10
Камрады, кто тесно работал с vtv, хотел уточнить. Ширина column задаётся жёстко на этапе создания дерева или можно в рантайме ее менять программно (не мышкой)?
Ed Doc
10
да ладно ... что там неочевидного ? глянуть в исх-ки датасета и/или кверика чтобы понять в каком месте и как выполняется обращения к св-вам blablaSQL - минутное дело, даже е...
Сергей
7
Здесь для arm кто-нибудь кодит ?
Nothing
52
Карта сайта