Как передать для Thread временные таблицы?

[Владимир Максимов]

Ax2009. Как передать в новую нить (Thred) содержимое временной таблицы?

У меня пока единственная идея - это конвертация содержимого таблицы в нечто более примитивное. Например, в контейнер через buf2con() / con2buf(). Но, может есть варианты без конвертации?

PS: GlobalCache - не работает, поскольку в новом Thread получаю чистый (новый) GlobalCache

Пока работаю так:

// Вызов Thread
void run()
{
    Thread      thread;
    Container   conHeader;
    ;

    while select headerData
    {
        conHeader += [global::buf2con(headerData)];
    }
    thread = new Thread();
    thread.setInputParm([conHeader]);
    thread.removeOnComplete(true);
    thread.run(classnum(MyClass), staticmethodstr(MyClass, runThread));
    thread.waitUntilSignaled();
    infolog.import(thread.getOutputParm());
}

// Обработка
static void runThread(Thread _thread)
{
    container   packedArgs;
    container   conHeader;
    container   conValue;
    int         nextI;

    MyClass  report;
    TmpTable     headerData;
    ;

    report = new MyClass();

    packedArgs = _thread.getInputParm();
    conHeader = conPeek(packedArgs, 1);
    for (nextI = 1; nextI <= conLen(conHeader); nextI++)
    {
        conValue = conPeek(conHeader, nextI);
        global::con2buf(conValue, headerData);
        headerData.insert();
    }
    // Метод через setTmpData() актуализирует временную таблицу в контексте класса
    report.setHeaderData(headerData);

    // Выполнение
    report.run();

    _thread.setOutputParm(infolog.copy(1,infolog.num()));

}

[Stitch_MS]

Вот тут предлагают Set.

[raz]

А почему не через параметры? Если все нити работают в одно время, то не вижу проблемы. Нужно проинициализировать курсор временной таблицы в самом начале (лучше на сервере) и его использовать.
Инициализировать так:

server static TmpTableName initTmpTableName()
{
    TmpTableName    tmpTableName;
    ;
    tmpTableName.clear();
    tmpTableName.insert();
    tmpTableName.delete();

    return tmpTableName;
}

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

[Logger]

Если не секрет, зачем вам thread ?
Если распараллеливаете задачу на потоки для ускорения, то лучше уж пакеты сделать с помощниками как в закрытии склада.

[Владимир Максимов]

Цитата:

Сообщение от Stitch_MS

Вот тут предлагают Set.

Хм... Те же контейнеры, но "вид сбоку" Впрочем, все-равно спасибо...

Цитата:

Сообщение от raz

А почему не через параметры?

Потому, что для Thread передать как параметр временную таблицу не получится. Передается только "голая" структура. Без данных.

Ну, или я "не умею их готовить" Можете сделать пример с использованием Thread, чтобы это работало?

Цитата:

Сообщение от Logger

Если не секрет, зачем вам thread ?

"Где бы, что ни говорили, все одно сведет на баб" (с)

Ответить-то я могу, это даже не секрет, но практика показывает, что после ответа на вопрос "зачем" обсуждение основного вопроса прекращается, и начинаются советы как делать по другому, чего не хотелось бы...

Цитата:

Сообщение от Logger

Если распараллеливаете задачу на потоки для ускорения, то лучше...

Вот об этом я и говорю... Для особо упорных - нет. Речь не идет об ускорении... Использование Thread необходимо, чтобы избежать некоторых ошибок в процессе исполнения. Т.е. отказаться от Thread можно, но сложно...

[raz]

Цитата:

Сообщение от Владимир Максимов

Можете сделать пример с использованием Thread, чтобы это работало?

Не получилось. А почему не использовать нормальную таблицу?

[Владимир Максимов]

Цитата:

Сообщение от raz

А почему не использовать нормальную таблицу?

Потому, что это временные данные Нужны только на время работы класса. По окончании работы класса удаляются.

[Logger]

Цитата:

Сообщение от Владимир Максимов

Потому, что это временные данные Нужны только на время работы класса. По окончании работы класса удаляются.

Дак в Аксапте таких данных дофига.
SalesParm*
PurchParm*

etc
Лень все перечислять.

[Logger]

Цитата:

Сообщение от Владимир Максимов

Использование Thread необходимо, чтобы избежать некоторых ошибок в процессе исполнения. Т.е. отказаться от Thread можно, но сложно...

Если вы захотите когда нить свою обработку засунуть в пакет, то обнаружите что thread в пакетном режиме не работают. И это будет облом.

[AndyD]

Не думаю, что это в принципе получится

Для каждого нового экземпляра Thread создается своя куча (убедиться в этом можно при помощи класса HeapCheck, созданного внутри потока), со своим набором объектов и курсоров
По-этому, в принципе нельзя получить ссылку на объект из другого потока

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

[Link]

Есть хороший пост на MSDN Threading in Dynamics AX.

[Logger]

Цитата:

Сообщение от AndyD

Не думаю, что это в принципе получится

Для каждого нового экземпляра Thread создается своя куча (убедиться в этом можно при помощи класса HeapCheck, созданного внутри потока), со своим набором объектов и курсоров
По-этому, в принципе нельзя получить ссылку на объект из другого потока

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

Интересно, почему же в серверном варианте они не создаются, а поток просто крешится поток при попытке обратиться.
Зависает Thread.run()

[Alex_KD]

Возможно в ax 2012. В 2009 не думаю что получится передать напрямую.

В 2012 есть метод Common.getPhysicalTableName() и если таблица TempDB то к ней можно достучатся напрямую через SQL (используется в change tracking в R3. см. метод \Classes\RetailCDXChangeTracking\runChangeTracking_table)

Если очень хочется, можно самому создавать временную таблицу на SQL (из X++), передавать ее имя в Thread, написать обертку вокруг всего этого ....

[Владимир Максимов]

Цитата:

Сообщение от Alex_KD

Если очень хочется, можно самому создавать временную таблицу на SQL (из X++), передавать ее имя в Thread, написать обертку вокруг всего этого ....

Сильно сомневаюсь...

Временная таблица MS SQL "живет" в рамках созданного соединения. В терминах Axapta: в рамках объекта Connection (или ODBCConnection или UserConnection). Но передать любой объект в новый Thread - невозможно! Следовательно, и про объект Connection можно забыть...

Нет, можно, конечно, делать глобальную временную таблицу, но это уже мало чем отличается от постоянной таблицы со всеми сопутствующими проблемами...

Или Thread всегда (?) работает в рамках того же самого соединения, не создавая нового?

[AndyD]

Не смешивайте, пожалуйста)

Для InMemory и в 2012 нельзя

[AndyD]

Коннекшен для TempDB неважен

Недавно приводили пример, как может заполняться таблица на самом SQL-сервере в хранимой процедуре

Для доступа к этой таблице достаточно передать ее имя (уникальное для сессии)

[Владимир Максимов]

Цитата:

Сообщение от AndyD

Коннекшен для TempDB неважен

Это как? Другой пользователь/сеанс может увидеть "мои" временные данные?

Цитата:

Сообщение от AndyD

Недавно приводили пример, как может заполняться таблица на самом SQL-сервере в хранимой процедуре

Для доступа к этой таблице достаточно передать ее имя (уникальное для сессии)

Это все будет работать только в том случае, если сессия не переключилась на другое соединение. В смысле, и ХП SQL-сервера и дальнейшее обращение к временной таблице выполнялось в рамках одного соединения к серверу. Пусть даже эти обращения были в разных классах, но соединение должно быть одно и то же!

На практике, гарантировать "не переключение" соединения на уровне Axapta можно только путем прямого контроля за объектом Connection. Все остальное - это "как повезет". Может получиться, а может и нет...

Тот факт, что, как правило, Axapta "держит" текущее соединение до окончания обработки, как раз и относится к таким "везениям". Некое действие по умолчанию, которое программист контролировать не может. Поэтому строить на этом какие-то далеко идущие выводы - не стоит.

[AndyD]

Цитата:

Сообщение от Владимир Максимов

Это как? Другой пользователь/сеанс может увидеть "мои" временные данные?

Совершенно верно
Одно условие - он должен знать имя таблицы (не аксаптовское, а физическое, что-нибудь типа такого [tempdb].[dbo].[t100005_E51B88936E814961BE9EFF89CE81E8D4]).

Насчет сессии, повторюсь, совершенно неважно
Я в Менеджмент студии руками заполнял значения таблицы, которая отображалась в интерфейсе аксапты

Насчет "удержания соединения" - это уже задача программиста, что бы оно удерживалось на время работы стороннего средства)

[Alex_KD]

Цитата:

Сообщение от AndyD

Не смешивайте, пожалуйста)

Для InMemory и в 2012 нельзя

Не смешиваю Я четко написал "если таблица TempDB то...".

Цитата:

Сообщение от AndyD

Одно условие - он должен знать имя таблицы (не аксаптовское, а физическое, что-нибудь типа такого [tempdb].[dbo].[t100005_E51B88936E814961BE9EFF89CE81E8D4]).

Вот именно поэтому передать значение в Thread очень даже возможно - передавайте название таблици и уже делаете что хотите с ней внутри Thread.

TmpTable tmpTable;

//fill tmpTable

thread = new Thread();
    thread.setInputParm([tmpTable.getPhysicalTableName()]);
    thread.removeOnComplete(true);
    thread.run(classnum(MyClass), staticmethodstr(MyClass, runThread));
    thread.waitUntilSignaled();
    
// tmpTable после работы Thread

tmpTable будет удалена автоматом как выйдите за рамки метода.

[Владимир Максимов]

Цитата:

Сообщение от AndyD

имя таблицы (не аксаптовское, а физическое, что-нибудь типа такого [tempdb].[dbo].[t100005_E51B88936E814961BE9EFF89CE81E8D4]).

Я так понимаю, это "фишка" Ax2012 и в Ax2009 не применима?

Тот факт, что у имени таблицы отсутствует ведущий символ "#", идентифицирующий именно временную таблицу в терминах MS SQL - это особенности "перевода" (пример) или действительно таблица создается в узле Table, а не в узле "Temporary Tables" базы данных tempdb? В смысле, если смотреть через MS SQL Server Management Studio.

Т.е. с точки зрения MS SQL - это именно временная таблица, живущая только в текущем соединении, или постоянная таблица просто созданная в базе tempdb?