Форум QUIK [тема: Синхронизация потоков]

Синхронизация потоков

Sat, 23 Oct 2021 16:29:22 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
Незнайка написал:
Почему так?
=============
table.ssort захватывает лок луа и не позволяет переключить поток с мейна на основной поток квика (или обратно). Между скриптами он не работает, у каждого скрипта свой лок.
23.10.2021 16:29:22, Anton.

Синхронизация потоков

Sat, 23 Oct 2021 16:19:09 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
_sk_ написал:
Есть следующий "хак", гарантирующий, что выполнение кода будет только в одном потоке.

====code====

   table.ssort ({  0 ,  1  },  function (a, b) 
  тут_ваш_код
   return   true 
 end )

=============
=============

Запускаю одновременно два скрипта. Использую "хак", рассчитывая, что скрипты будут писать в файл по очереди:

Скрытый текст
====code==== local f function OnInit() f = assert(io.open(getScriptPath() .. "\\file.txt", "a")) end function main() table.ssort({0, 1}, function () for i = 1, 100 do f:write("1\n") f:flush() end return true end) f:close() end ============= ====code==== local f function OnInit() f = assert(io.open(getScriptPath() .. "\\file.txt", "a")) end function main() table.ssort({0, 1}, function () for i = 1, 100 do f:write("22\n") f:flush() end return true end) f:close() end =============

Скрытый текст

Но в файле строки оказываются вперемешку:

Скрытый текст
====quote==== 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 22 1 1 22 22 22 22 1 22 1 22 22 22 22 1 22 1 22 1 22 1 22 =============

Почему так? "Хак" не работает с файловыми операциями?
23.10.2021 16:19:09, Незнайка.

Синхронизация потоков

Tue, 13 Jul 2021 15:53:37 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
Sergey написал:
Прошу помочь в синхронизации потоков.
=============
В документе разработчика QUIK: «Использование Lua в Рабочем месте QUIK.pdf», в разделе «2. Взаимодействие потоков Lua скрипта» описана рекомендуемая схема обработки колбеков. Если придерживаться ее, то проблем многопоточности (! из-за того, что колбеки запускаются в потоке отличном от потока main) в скрипте пользователя не будет.
По ссылке https://forum.quik.ru/messages/forum10/message56397/topic6356/#message56397 вы найдете пример из раздела «2. Взаимодействие потоков Lua скрипта».
13.07.2021 15:53:37, TGB.

Синхронизация потоков

Tue, 13 Jul 2021 13:37:22 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
Sergey написал:
2 поток удалил запись с индексом 3
1 поток удаляет запись с индексом 5 - это уже не та запись, которую он нашел - это проблема.
=============

Если оба потока удаляют записи в таблице, то да, нужна синхронизация.
13.07.2021 13:37:22, Старатель.

Синхронизация потоков

Tue, 13 Jul 2021 12:00:14 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
Старатель написал:

Поскольку вы используете потокобезопасные функции, то добавление элемента в конец таблицы (именно такая запись без указания индекса table.sinsert(Trades, trade)) не влечет каких-то неприятных последствий.
=============
Удаление влечет последствия:
1 поток нашел, что ему нужно удалить запись с индексом 5 но пока не удалил
2 поток удалил запись с индексом 3
1 поток удаляет запись с индексом 5 - это уже не та запись, которую он нашел - это проблема.
13.07.2021 12:00:14, Sergey.

Синхронизация потоков

Tue, 13 Jul 2021 08:33:02 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
Sergey написал:
В нее добавляются и из нее удаляются элементы в потоке main и колбеках функциями: ====code====

table.sremove (Trades, i) 
table.sinsert (Trades, trade)

=============
Проблема в том, что перед добавлением/удалинием элементов происходит перебор элементов таблицы в цикле для поиска нужного индекса. Если нужный элемент найден, а другой поток удалит элемент с меньшим индексом, то индексы сдвинутся и получится ерунда, т.е. нужно синхронизировать потоки.
=============

Поскольку вы используете потокобезопасные функции, то добавление элемента в конец таблицы (именно такая запись без указания индекса table.sinsert(Trades, trade)) не влечет каких-то неприятных последствий.
13.07.2021 08:33:02, Старатель.

Синхронизация потоков

Wed, 30 Jun 2021 23:47:21 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
Поясните пожалуйста, если main с бесконечным циклом без С-функций, в конце каждой итерации sleep это будет работать так:
1. Если выполняется код до sleep и приходит колбэк, то колбэк не будет выполняться, пока не начнет выполняться sleep.
2. При начале выполнения sleep, начнут выполняться накопленные колбеки, при этом в основном потоке дальше sleep выполнение не пойдет, пока не выполнятся все накопленные колбеки?
=============
Да. Тут надо уточнить что использование динамической памяти тоже снимает лок - создание новых объектов и строк. При использовании полностью статической памяти и отсутствии манипуляции строк, лок не должен сниматься. Еще надо уточнить что каждый луа-скрипт имеет свой отдельный тред, но колбеки выполняются из главного треда квика, так что пока колбек (любой из них) выполняется или стоит в ожидании, весь терминал будет висеть.
30.06.2021 23:47:21, Артем.

Синхронизация потоков

Wed, 30 Jun 2021 13:14:14 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
Артем написал:
Код, не вызывающий никаких С-функций, выполняется атомарно. Так что можно использовать глобальные переменные в качестве мутексов.
=============
Поясните пожалуйста, если main с бесконечным циклом без С-функций, в конце каждой итерации sleep это будет работать так:
1. Если выполняется код до sleep и приходит колбэк, то колбэк не будет выполняться, пока не начнет выполняться sleep.
2. При начале выполнения sleep, начнут выполняться накопленные колбеки, при этом в основном потоке дальше sleep выполнение не пойдет, пока не выполнятся все накопленные колбеки?
30.06.2021 13:14:14, Sergey.

Синхронизация потоков

Wed, 30 Jun 2021 10:01:05 +0300

Синхронизация потоков в форуме Программирование на языке Lua.

====quote====
Sergey написал:
Спасибо, за ответ. А потоки синхронизировать в Lua можно?
=============
Код, не вызывающий никаких С-функций, выполняется атомарно. Так что можно использовать глобальные переменные в качестве мутексов.
30.06.2021 10:01:05, Артем.

Синхронизация потоков

Wed, 30 Jun 2021 08:32:41 +0300

Синхронизация потоков в форуме Программирование на языке Lua.
Спасибо!
30.06.2021 08:32:41, Sergey.

Синхронизация потоков

Wed, 30 Jun 2021 08:19:40 +0300

Синхронизация потоков в форуме Программирование на языке Lua.
Есть следующий "хак", гарантирующий, что выполнение кода будет только в одном потоке.

====code====

table.ssort({ 0, 1 }, function(a, b) 
  тут_ваш_код
  return true
end)

=============
Идея в том, что выполняется "бесполезный" ssort на таблице из двух элементов с указанным компаратором. Ваш код выполнится один раз внутри этого компаратора.

Только не надо злоупотреблять этим, иначе терминал начнёт тормозить.
30.06.2021 08:19:40, _sk_.

Синхронизация потоков

Wed, 30 Jun 2021 08:11:53 +0300

Синхронизация потоков в форуме Программирование на языке Lua.
Спасибо, за ответ. А потоки синхронизировать в Lua можно?
30.06.2021 08:11:53, Sergey.

Синхронизация потоков

Wed, 30 Jun 2021 05:12:26 +0300

Синхронизация потоков в форуме Программирование на языке Lua.
Решение очень простое: не используйте одни и те же данные в разных потоках. Один из примеров практической реализации такого принципа это двойная буферизация.
30.06.2021 05:12:26, Артем.

Синхронизация потоков

Tue, 29 Jun 2021 21:09:50 +0300

Синхронизация потоков в форуме Программирование на языке Lua.
Добрый день.
Прошу помочь в синхронизации потоков.
Есть глобальная таблица ====code====

Trades = {}

============= В нее добавляются и из нее удаляются элементы в потоке main и колбеках функциями: ====code====

table.sremove(Trades, i) 
table.sinsert(Trades, trade)

=============
Проблема в том, что перед добавлением/удалинием элементов происходит перебор элементов таблицы в цикле для поиска нужного индекса. Если нужный элемент найден, а другой поток удалит элемент с меньшим индексом, то индексы сдвинутся и получится ерунда, т.е. нужно синхронизировать потоки. В с++ я бы использовал mutex, в lua я нашел подобие mutex (возможно ошибаюсь), функции:
https://www.lua.org/manual/2.1/section3_5.html
====code====

int        lua_lock (void);
lua_Object lua_getlocked  (int ref);
void       lua_pushlocked (int ref);
void       lua_unlock (int ref);

============= но я не понимаю как их использовать и не могу найти примеры (судя по объявлению функций это вообще с++).
Подскажите как можно решить проблему или где найти примеры/описание?
29.06.2021 21:09:50, Sergey.