Параллельная обработка данных

[tourist]

Перед транзакцией делайте trans.reread() и еще раз проверяйте условие селекта
т.е
trans.reread();
if(trans.open)
{
ttsbegin;
...

[Volodymyr]

Это не решит проблемы.
Ведь всеравно два батча будут работать хуже чем один...

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

Наверное два всегда хуже чем один...
Интересно, можно ли как то в селекте выбрать линии, которые точно не проапдейтятся другим батчем?

[tourist]

выбор по четным и нечетным recId

[Volodymyr]

=) Смешно... но всетаки

Вобщем задача свелась к тому, что нужно в цикле проверить можнло ли залочить текущую линию , если да, то залочиеть ее , иначе продолжить цикл (т.е. перейти к следующей линии)

Как это реализовать пока незнаю

[Hyper]

Цитата:

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

Интересно, можно ли как то в селекте выбрать линии, которые точно не проапдейтятся другим батчем?

Вторым батчем пойти задом наперед.

run()
{
    Trans   trans;
    Trans   buffer;
    boolean reversed;
    ;
    
    try
    {
        select trans
            order by RecId asc
            where trans.open;

        while (trans)
        {
            buffer = Trans::find(trans.recid);
            
            if (!buffer.open)
            {
                if (!reversed)
                {
                    reversed = true;
                    
                    select trans
                        order by RecId desc
                        where trans.open;
                        
                    continue;
                }
                else
                {
                    break;
                }
            }
                
            ttsbegin;
            buffer.selectForUpdate(true);
            buffer.open = false;
            buffer.doUpdate();
            .......
            buffer.update()
            ttscommit;
            
            next trans;
        }
    }
    
    catch (Exception::Deadlock)
    {
        retry;
    }
    
    catch (Exception::UpdateConflict)
    {
        retry;
    }
}

Третий батч просто вылетит.

[Volodymyr]

TO Stich_MS: К сожалению когда один батч выполняет

PHP код:

select pessimisticLock firstonly trans
    where trans.open == true; 


То второй батч при выборе этой же линии, ждет пока снимется лок сделаный первым батчем. Т.е. получается вообще плохо.
To Hyper: вот это подход я понимаю , но всетаки запуск больше двух батчей не приведет к ускорению работы.

Пришлось сделать так:
1) Добавить на таблицу поле Blocked
2) Переделать метод так:

PHP код:

run()
{
    Trans trans;
    Trans buffer;
    boolean setBlocked(boolean _blocked)
    {
        if (_blocked && trans.blocked)
            return false;
 
        ttsbegin;
        buffer = Trans::find(trans.recId, true);
        buffer.blocked = true;
        buffer.update();
        ttscommit;
        return buffer.blocked;
    }
    try
    {
        while select trans where trans.open == true && trans.blocked == false
        {
            if(setBlocked(true))
            {
                ttsbegin;
                buffer = Trans::find(trans.recid, true);
                ...
                buffer.open = false;
                buffer.update();
                ttscommit;
                setBlocked(false);
            }
        }
    }
    catch (Exception::Error)
    {
        setBlocked(false);
    }
    catch (Exception::UpdateConflict)
    {
        retry;
    }
} 


Всех с Праздником!