[translate] BackGround

Форум » [x]Harbour » [translate] BackGround » Ответить

[translate] BackGround

Dima: Кто то может перевести help к этим функциям на русский ? HB_BackGroundActive() Queries and/or changes the activity of a single background task. HB_BackGroundAdd() Adds a new background task. HB_BackGroundDel() Removes a background task from the internal task list. HB_BackGroundReset() Resets the internal counter of background tasks. HB_BackGroundRun() Enforces execution of one or all background tasks. HB_BackGroundTime() Queries or changes the wait interval in milliseconds after which the task is executed. HB_IdleAdd() Adds a background task for being executed during idle states. HB_IdleDel() Removes a task from the list of idle tasks. HB_IdleReset() Resets the internal counter of idle tasks. HB_IdleSleep() Halts idle task processing for a number of seconds. HB_IdleSleepMSec() Queries or changes the default time interval for idle task processing. HB_IdleState() Signals an idle state. HB_IdleWaitNoCPU() Toggles the mode for CPU usage in Idle wait states. SET BACKGROUND TASKS Enables or disables the activity of background tasks. SET BACKGROUNDTICK Defines the processing interval for background tasks.

Ответов - 96, стр: 1 2 3 4 5 All

Петр: HB_BackGroundAdd() - добавляет новую фоновую задачу Синтаксис: HB_BackGroundAdd( <bAction>, [<nMillisecs>], [<lActive>] ) --> nTaskHandle Аргументы: <bAction> Блок кода, который должен выполнятся в фоновом режиме. <nMillisecs> Необязательный числовой параметр, определяющий временной интервал в миллисекундах, после которого фоновая задача будет выполнена. Значение по умолчанию равно 0, а это значит, что фоновая задача вызывается каждый раз при проверке внутреннего списка задач фонового исполнения (имеется ввиду проверка внутренним обработчиком). <lActive> Значение по умолчанию для <lActive> равно .T. (ИСТИНА) приводит к тому, что <bAction> будет отмечен для немедленной фоновой деятельности. Передача же значения .F. (ЛОЖЬ) добавит задачу в внутренний список задач, но задача начнет выполняться после активирования ее посредством функции HB_BackGroundActive(). Возвращаемое значение: Функция возвращает числовой дескриптор задачи, который вы обязательно должны сохранить, хотя бы для того, что бы в последствии удалить задачу с помощью HB_BackGroundDel() или использовать для других функций управления фоновыми задачами. Описание: Функция HB_BackGroundAdd() добавляет передаваемый ей в качестве аргумента блок кода в список фоновых задач которые будут выполнятся одновременно с главной программой. Ограничение на число фоновых задач не установлено. Обработка фоновых задач должна быть включена командой SET BACKGROUND TASKS ON. Фоновые задачи обрабатываются секвенциально (последовательно) пока не будет SET BACKGROUND TASKS OFF или столкнемся с состоянием ожидания. Состояние ожидания есть такое состояние xHarbour virtual machine , в котором она (VM) ожидает пользовательский ввод с клавиатуры или события от мыши. VM входит в состояние ожидания при вызовах Inkey(). Все приложения, которые не использую вызовы функции Inkey() могут сигнализировать о состоянии ожидания посредством вызова функции HB_IdleState() (can signal the idle state with a call to the HB_IdleState() function) . Примечение: для предотвращения прерывания фоновой обработки во время состояния ожидания задача ожидания должна быть определена как HB_IdleAdd( {||HB_BackGroundRun()} ). Альтернатива фоновым задачам представлена потоками. Обратитесь к описанию функции StartThread() для одновременного выполнения частей приложения в различных потоках. HB_BackGroundActive() - Запрашивает и/или изменяет активность одиночной фоновой задачи. Синтаксис: HB_BackGroundActive( <nTaskHandle> [, <lNewActive>] ) --> lOldActive Параметры: <nTaskHandle> Дескриптор (числовой) фоновой задачи полученый в результате выполнения функции HB_BackGroundAdd(). <lNewActive> Логическое значение (необязательный параметр) используемое для изменения активности фоновой задачи. Передавая .T. (ИСТИНА) можно активировать фоновую задачу и .F. (ЛОЖЬ) деактивировать ее. Возвращаемое значение: Функция возвращает предыдущее состояние (состояние до вызова функции) активности фоновой задачи, как логическое значение или NIL (см.ниже). Описание: Функция HB_BackGroundActive() опрашивает и изменяет (необязательно) состояние активности одиночной фоновой задачи. Если дескриптор задачи, возвращенный HB_BackGroundAdd() валидный (правильный), функция возвращает предыдущее состояние. Если передан неправильный дескриптор фоновой задачи, возвращаемое значение есть NIL.

Петр: А собственно какой перевод нужен и зачем - такой вот подойдет ?

Dima: Петр пишет: А собственно какой перевод нужен и зачем - такой вот подойдет ? Да такой перевод подходит !!! Есть одна задачка , которая должна обработать запросы с 20 станций одновременно и работать она должна круглосуточно. Можно остальной перевод ? Хочу представлять как это работает , остальное сам докумекаю. Спасибо !!!!!!!!!!!!!!!!!!

Петр: Dima пишет: Есть одна задачка , которая должна обработать запросы с 20 станций одновременно и работать она должна круглосуточно. Боюсь background здесь не пройдет, для решения такой задачи вам нужно An alternative for background tasks is provided with threads. Refer to function StartThread() for running parts of an application simultaneously in multiple threads. Альтернатива фоновым задачам представлена потоками. Обратитесь к описанию функции StartThread() для одновременного выполнения частей приложения в различных потоках. Только вот незадача - MT в xHarbour реализован не полностью и не совсем корректно. Если религия позволяет ( ) посмотрите на Harbour. Dima пишет: Можно остальной перевод ? Если действительно нужно - то сделаю сегодня. Хотя я к себе в роли переводчика отношусь мягко говоря с улыбкой

Dima: Петр Спасибо , ушел думать ;) !

Петр: HB_BackGroundDel() - удаляет фоновую задачу из внутреннего списка задач. Синтаксис: HB_BackGroundDel( <nTaskHandle> ) --> bAction Параметры: <nTaskHandle> Числовой дескриптор фоновой задачи, полученный в результате выполнения функции HB_BackGroundAdd(). Возвращаемое значение: Функция возвращает блок кода связанный с дескриптором задачи ( т.е. блок кода переданный функции HB_BackGroundAdd()) или NIL если указан неверный дескриптор. Описание Функция HB_BackGroundDel() удаляет задачу связанную с переданным в качестве аргумента дескриптором, из внутреннего списка фоновых задач. Дескриптор фоновой задачи должен быть значением, которое возвращено предыдущим вызовом функции HB_BackGroundAdd(). Если указанная задача существует, она деактивируется и связанный с ней блок кода будет возвращен в качестве результата выполнения HB_BackGroundDel(). Как было указано выше, если указан неверный дескриптор - функция возвратит NIL. HB_BackGroundReset() - сбрасывает внутренний счетчик фоновых задач. Синтаксис: HB_BackGroundReset() --> NIL Возвращаемое значение: Возвращаемое значениеs всегда равно NIL. Описание Функция HB_BackGroundReset() устанавливает значение внутреннего счетчика фоновых задач (определяющий следующую задачу, которая будет выполнятся) равным 1. Как результат, следующий цикл фоновой обработки стартует с задачи, которая была определена первой. HB_BackGroundTime() получает или изменяет период ожидания (в миллисекундах) после истечения которого задача начинает выполнятся. Синтаксис: HB_BackGroundTime( ( <nTaskHandle> [, <nNewInterval>] ) --> nOldInterval Параметры: <nTaskHandle> Числовой дескриптор фоновой задачи, полученный в результате выполнения функции HB_BackGroundAdd(). <nNewInterval> Необязательный числовой параметр, определяющий временной интервал в миллисекундах, который фоновая задача должна выждать между двумя циклами выполнения. Если nNewInterval установлен в 0, фоновая задача вызывается каждый раз при проверке внутреннего списка задач фонового исполнения. Возвращаемое значение: Функция возвращает раннее установленный интервал ожидания фоновой задачи в виде числового значения (в миллисекундах) или NIL в случае если вы передали функции неверный дескриптор задачи Описание: Функция HB_BackGroundTime() запрашивает или изменяет число миллисекунд, после которых задача начинает выполнятся. Как правило, временной интервал определяется значением передаваемым в качестве второго аргумента функции HB_BackGroundAdd(). HB_BackGroundRun() - предписывает выполнение одной или всех фоновых задач. Синтаксис: HB_BackGroundRun( [<nTaskHandle>] ) --> NIL Параметры: <nTaskHandle> Числовой дескриптор фоновой задачи, полученный в результате выполнения функции HB_BackGroundAdd(). Если опущен, все фоновые задачи будут выполнены. Возвращаемое значение: Возвращаемое значениеs всегда равно NIL. Описание: Функция HB_BackGroundRun() выполняет одиночную фоновую задачу определяемую <nTaskHandle> или все задачи из внутреннего списка задач, в случае если <nTaskHandle> если не определен (т.е. если функция вызывается без аргументов). Функция может быть использована для принудительного запуска фоновой задачи во время нормального выполнения программы или во время пребывания программы в состоянии ожидания. Примечание: HB_BackGroundRun() выполняет задачу указанную <nTaskHandle> немедленно, даже если период ожидания, указанный для данной задачи не истек или фоновая задача находится в неактивном состоянии.

Петр: SET BACKGROUNDTICK - определяет интервал обработки для фоновых задач. Синтаксис: SET BACKGROUNDTICK <nInterval> Аргументы: <nInterval> Числовое значение определяющее число инструкций обработанных виртуальной машиной xHarbour (VM) перед началом нового цикла обработки фоновой задачи. Значение по умолчанию равно 1000. Описание: SET BACKGROUNDTICK может быть использовано для "тюнинга" ( согласования, гармонии ) обработки фоновой задачи. Значение по умолчанию 1000 обычно адекватно для хорошего баланса между нормальной и фоновой обработкой задач. Фоновые задачи выполняются одновременно с главной программой. Если увеличивать <nInterval>, главная программа получит больше процессорного времени, вследствии чего меньше времени получит обработчик фоновых задач. Уменьшение <nInterval> улучшит время отклика для фоновых задач (но может ухудшить общую производительность программы - прим. переводчика ).

Петр: SET BACKGROUND TASKS - разрешает или запрещает деятельность фоновых задач. Синтаксис: SET BACKGROUND TASKS on | OFF | (<lOnOff>) Параметры: on | OFF | (<lOnOff>) Опции переключения активности фоновых функций, созданных HB_BackGroundAdd(). При ON или .T. (ИСТИНА), обработка фоновых задач доступна. OFF или .F. (ЛОЖЬ), установлено по умолчанию, запрещает обработку фоновых задач. Описание: SET BACKGROUND TASKS переключает (включает.выключает) активность обработки фоновых задач. Фоновые задачи создаются функцией HB_BackGroundAdd() и выполняются одновременно с нормальными задачами программы. Используйте HB_IdleAdd() для обработки паралельных (одновременных) задач только во время состояния ожидания. Для доступности обработки фоновых задач SET BACKGROUND TASKS должен быть установлен в ON.

Петр: Во время перевода окончательно убедился, что функции HB_IdleAdd() Добавляет фоновую задачу для началы выполнения во время состояния бездействия. HB_IdleDel() Удаляет задачу с списка задач ожидания. HB_IdleReset() Сбрасывает состояние счетчика задач ожидания. HB_IdleSleep() Приостанавливает выполнение задач ожидания на n секунд. HB_IdleSleepMSec() Запрашиват или изменяет интервал времени по умолчанию для обработки задач ожидания. HB_IdleState() Указывает на состояние ожидания. HB_IdleWaitNoCPU() Toggles the mode for CPU usage in Idle wait states. вам не пригодятся. Трудно представить задачу которая "должна обработать запросы с 20 станций одновременно и работать она должна круглосуточно" и при этом еще должна ждать от пользователя ввод с клавиатуры или мыши. Но если вдруг перевод таки понадобится, вам или кому нибудь другому, то смогу сделать толькозавтра вечером.

Dima: Петр Огромное спасибо дружище !!!!!!!!!

Andrey: Дима, ты бы хелпик сделал для всех.... Для чего использовать, примеры там.... Всем было бы интересно...

Dima: Andrey Андрей ну примеры то еcть однако , например mtstress.prg mttest.prg У меня тут лежат выкачанные с CVS C:\CVS\xharbour\tests\

Dima: Петр а если у меня задача находится все время в состоянии бездействия и просто сканирует определенные папки и выполняет операции с файлами (без участия пользователя , типа "сервер") имеет ли значение что использовать HB_IdleAdd() или HB_BackGroundAdd() ?

Петр: Dima пишет: а если у меня задача находится все время в состоянии бездействия и просто сканирует определенные папки и выполняет операции с файлами Т.е. inkey() не используется? В этом случае нужно или пользоваться HB_IdleAdd() или если использовать HB_BackGroundAdd, то примерно так [pre2]PROCEDURE Main LOCAL nTask, nIdle SET BACKGROUND TASKS ON nIdle := HB_IdleAdd( {|| HB_BackGroundRun() } ) // обязательно !! nTask := HB_BackGroundAdd( {|| ShowTime() }, 1000 ) //здесь что-то делаем HB_BackGroundDel( nTask ) HB_IdleDel( nIdle ) RETURN [/pre2]

Dima: У меня примерно так [pre2] PROCEDURE Main LOCAL nIdle,i,barray:=Array(3) SET BACKGROUND TASKS ON for i=1 to 3 // вроде пашет в 3 потока barray := HB_IdleAdd({@TEST(),i}) next do while inkey(0)#27 enddo //функция Test и занимается работой с каталогами и базами for i=1 to 3 HB_IdleDel( barray ) next SET BACKGROUND TASKS OFF RETURN [/pre2] Есть какие то неточности или это полный бред ? PS Форум снова скушал скобки.......

Dima: Меня терзают смутные сомнения..... Предположим функция Test находится в процессе обработки базы данных и в этот момент я жму Esc , завершится нормально текущий "Task" или нет ?

Петр: Dima пишет: завершится нормально текущий "Task" или нет ? В такой реализации скорее всего буду проблемы. Теперь по поводу неточностей. наверное правильнее будет barray{i} := HB_IdleAdd(.. .. HB_IdleAdd(barray{i}) и зачем SET BACKGROUND TASKS ON SET BACKGROUND TASKS OFF если HB_BackgroundAdd не используется..

Dima: С удивлением обнаружил что HB_idledel всегда возвращает NIL Например Idletest.prg из \Tests

Петр: Dima пишет: HB_idledel всегда возвращает NIL в Harbour все правильно ? hb_IsBlock(hb_IdleDel(id)) - > .T. Все равно - в твоем случае я бы с MT эксперементировал.

Dima: Петр пишет: Все равно - в твоем случае я бы с MT эксперементировал я бы рад , но не могу ADS приручить для этого режима. бьет ошибку подробности тут http://clipper.borda.ru/?1-4-0-00000362-000-30-0-1223645823

Петр: Извини, нет у меня ACE SDK - помочь не могу. Если ссылку (не с оффсайта) выложишь, тогда можно было бы посмотреть.

Dima: Петр http://files.mail.ru/QRP8D5

Петр: Dima пишет: но не могу ADS приручить для этого режима. бьет ошибку Дима у меня с тем ace sdk, что ты выложил все получилось нормально - без ошибок.. Делал так: обновил xHarbour с CVS, используя make_b32 пересобрал, предварительно сделав make_b32 clean. Зашел в contrib\rdd_ads. В make_b32.bat добавил set HB_DIR_ADS=e:\extlib\acesdk и установил set CFLAGS=%_CFLAGS% -I"%HB_DIR_ADS%" -tWM -DHB_THREAD_SUPPORT -DADS_LIB_VERSION=550 далее выполнил make_b32.bat clean // на всякий случай make_b32.bat потом зашел в tests в bldtest.bat прописал set HB_USER_LIBS=ace32.lib rddads.lib в ads.prg добавил в начало программы ? HB_MULTITHREAD() // тоже, на всякий случай bldtest.bat /MT ads запустил ads.exe - все Ok - это я шучу - перед тем как радоваться пришлось ads.prg немного поправить, алиасы указать..

Dima: Петр пишет: set CFLAGS=%_CFLAGS% -I"%HB_DIR_ADS%" -tWM -DHB_THREAD_SUPPORT -DADS_LIB_VERSION=550 А вот так действительно собралось ;) Спасибо !!!

Dima: Это собрался мини примерчик. В реальной задаче проблема с HBZIP.LIB во время сборки Error: Unresolved external '_errno' referenced from C:\X\LIB\HBZIP.LIB|zipfile Что править и где для MT режима ?

Петр: В CONTRIB\HBZLIB\makefile.bc есть строчка CompInheritOptsAt_ziparddll = -I$(BCB)\INCLUDE -Iinclude -I..\..\include;.;..\..\source\rtl\zlib.. после нее добавь CompInheritOptsAt_ziparddll = -tWM $(CompInheritOptsAt_ziparddll) или просто всунь -tWM где нибудь в CompInheritOptsAt_ziparddll, например CompInheritOptsAt_ziparddll = -tWM -I$(BCB)\INCLUDE и дальше привычное make_b32.bat clean make_b32.bat Компилируя с этим флагом мы заставляем linker искать стандартные C-функции в cw32mt.lib. Можно это сделать и по другому, но это самый простой путь, к тому же правильный.

Dima: Петр Спасибо , все собралось замечательно !!!!!!!!!!!!!!!

Dima: Петр пишет: PROCEDURE Main LOCAL nTask, nIdle SET BACKGROUND TASKS ON nIdle := HB_IdleAdd( {|| HB_BackGroundRun() } ) // обязательно !! nTask := HB_BackGroundAdd( {|| ShowTime() }, 1000 ) //здесь что-то делаем HB_BackGroundDel( nTask ) HB_IdleDel( nIdle ) RETURN Cделал так [pre2] PROCEDURE Main LOCAL nTask, nIdle SET BACKGROUND TASKS ON nIdle := HB_IdleAdd( {|| HB_BackGroundRun() } ) nTask := HB_BackGroundAdd( {|| Test() }, 1000 ) do while inkey(0)#27 enddo do while HB_BackGroundActive(nTask,.f.) // этот кусок кода гарантирует что функция Test завершится enddo // коректно или это нужно делать иначе ? HB_BackGroundDel( nTask ) HB_IdleDel( nIdle ) SET BACKGROUND TASKS OFF RETURN [/pre2]

Петр: Dima пишет: do while HB_BackGroundActive(nTask,.f.) // этот кусок кода гарантирует что функция Test завершится enddo // коректно или это нужно делать иначе ? Увы, не гарантирует. HB_BackGroundActive(nTask,.f.) просто сразу деактивирует задачу и все. Нужно понимать HB_BackGroundActive() дает возможность установить не то, выполняется ли сейчас функция Test, а будет ли она выполнятся по прошествии nTimeOut или не будет.

Dima: Петр Буду думать , спасибо !!!

Петр: Dima пишет: Буду думать Harbour + MT: пример [pre2]#include "hbthread.ch" MEMVAR lExit // PROCEDURE main LOCAL threadA, threadB, xResult := NIL PUBLIC lExit := .F. threadB := hb_threadStart( HB_THREAD_INHERIT_PUBLIC, @MyFuncB() ) threadA := hb_threadStart( HB_THREAD_INHERIT_PUBLIC, @MyFuncA() ) __keyboard(chr(27)) // можно закомментировать hb_threadJoin( threadA, @xResult ) ? xResult hb_threadJoin( threadB, @xResult ) ? xResult // RETURN /* */ STATIC FUNCTION MyFuncA( ) DO WHILE inkey( 0.1 ) != 27 ENDDO lExit := .T. // RETURN LastKey() /* */ STATIC FUNCTION MyFuncB( ) LOCAL nCounter, nI DO WHILE !lExit nCounter := 0 FOR nI := 1 TO 10000 nCounter ++ NEXT nI END // RETURN nCounter[/pre2]

Петр: Ценой, просто невероятных умственных усилий удалось портировать в xHarbour [pre2]STATIC lExit // PROCEDURE main LOCAL threadA, threadB, nCounter := 0 lExit := .F. threadB := StartThread( @MyFuncB(), @nCounter ) threadA := StartThread( @MyFuncA() ) __keyboard(chr(27)) JoinThread( threadA ) ? LastKey() JoinThread( threadB ) ? nCounter // RETURN /* */ STATIC PROCEDURE MyFuncA( ) DO WHILE inkey( 0.1 ) != 27 ENDDO lExit := .T. // RETURN /* */ STATIC PROCEDURE MyFuncB( nCounter ) LOCAL nI DO WHILE !lExit nCounter := 0 FOR nI := 1 TO 10000 nCounter ++ NEXT nI ThreadSleep( 10 ) END // RETURN[/pre2] В результате выполнения этих програм, мы получаем на выходе 27 10000 А это значит, что функция (процедура) MyFuncB вполне корректно выполняется, что нам и требовалось. Можно закомментировать __keyboard(chr(27)) и поиграться

Dima: Петр пишет: threadB := StartThread( @MyFuncB(), @nCounter ) threadA := StartThread( @MyFuncA() ) __keyboard(chr(27)) Спасибо вроде разобрался ;) Но такой код срабатывает 1 раз. Для того что он работал все время нужно сделать так threadB := StartThread( @MyFuncB(), @nCounter ) threadA := StartThread( @MyFuncA() ) WaitForThreads() __keyboard(chr(27)) Не совсем понял что делает JoinThread Не проще ли так StopThread(threadA) StopThread(threadB) Или KillAllThreads()

Петр: Dima пишет: Но такой код срабатывает 1 раз. Это с __keyboard(chr(27)) - мне просто лень ESC нажимать Закомментируй и посмотри - все выполняется в цикле, как надо. Не проще ли так StopThread(threadA) StopThread(threadB) Нет, мы просто остановим потоки и в результате 10000 на экране можем не увидеть JoinThread приостанавливает выполнение главного потока, созданого по умолчанию и дожидается выполнения потока А, т.е. пока мы не нажмем ESC. Дальше JoinThread( threadB ) дожидается завершения выполнения потока Б. Ну а так ( KillAllThreads() ) убивать потоки не рекомендую вообще, за исключением действий при форсмажорных обстоятельствах.

Dima: Петр Есть проблемка тогда , даже 2 Если использовать JoinThread то прога падает Subsystem Call ....: BASE System Code .......: 3012 Default Status ....: .F. Description .......: Given thread is not valid Operation .........: JOINTHREAD Arguments .........: [ 1] = Type: P Val: A91FD0 Кроме того AdsIsServerLoaded всегда возвращает 0 (в MT режиме , в обычном все нормально)

Dima: Виноват , поправка Забыл отключить WaitForThreads() И JOINTHREAD сработал А вот с AdsIsServerLoaded проблема осталась

Dima: Очередной глюк в MT режиме :( ? AdsIsServerLoaded(CurDrive()+":\"+CurDir()+"\DBF\"+"data_nul.dbf") // локальный ADS , возвращает 0 Причем до вызова всех StartThread , AdsIsServerLoaded работает правильно ? AdsIsServerLoaded("\\servak\sys\test\data_nul.dbf") // как и положено вернет 2 , remote ADS В обычном режиме все нормально.......

Dima: Вообщем решил пока не использовать Local Ads , так как не коннектится в MT режиме

Dima: Петр А если 3 потока то как правильно сделать ? [pre2] PROCEDURE main LOCAL threadA, threadB,threadC lExit := .F. threadC := StartThread( @MyFuncC()) threadB := StartThread( @MyFuncB()) threadA := StartThread( @MyFuncA() ) JoinThread( threadA ) JoinThread( threadB ) JoinThread( threadC ) // тут иногда падает RETURN [/pre2]

Петр: threadC просто не инициилизировался. xHarbour падает и на двух потоках - убери из моего примера ThreadSleep( 10 ) и убедись: STATIC PROCEDURE MyFuncB( nCounter ) LOCAL nI DO WHILE !lExit nCounter := 0 FOR nI := 1 TO 2 nCounter ++ NEXT nI END // RETURN Что может оттянуть (предотвратить) падение - в MyFuncC добавь перед выходом ThreadSleep( nTimeOut ). Для Win nTimeOut == 20 в самый раз или проводи проверки IF hb_IsPointer(threadC) ; JoinThread( threadC ) ; ENDIF

Dima: Петр Спасибо !!!

Dima: Петр В чем разница ? Похоже и в том и другом случае все завершается коректно. [pre2] PROCEDURE main LOCAL threadA, threadB threadB := StartThread( @MyFuncB()) threadA := StartThread( @MyFuncA() ) JoinThread( threadA ) JoinThread( threadB ) RETURN [/pre2] ********************************* [pre2] PROCEDURE main LOCAL threadA, threadB threadB := StartThread( @MyFuncB()) threadA := StartThread( @MyFuncA() ) WaitForThreads() RETURN [/pre2] И еще вопросы. Можно ли в функции MyFuncB() , стартовать еще потоки на выполнение (StartThread) ? Для чего нужна функция HB_MutexCreate() ?

Dima: Петр Будет ли верно работать такой код или нужно что то поправить ? [pre2] STATIC lExit Global Puts Global cserv PROCEDURE main LOCAL threadA, threadB lExit := .F. puts:="C:\TEST" cserv:="\\servak\sys\sklad" threadB := StartThread( @MyFuncB()) threadA := StartThread( @MyFuncA()) JoinThread( threadA ) JoinThread( threadB ) RETURN ************************* func MyFuncB() local adir LOCAL aFile local aExtract local nind:=0 DO WHILE !lExit adir:=Directory(puts+"A*.zip") if len(adir)>0 FOR EACH aFile IN aDir aExtract := hb_GetFilesInZip( puts+afile[1]) IF HB_UNZIPFILE( puts+afile[1],,,,cserv,aExtract) nind:=val(substr(afile[1],2,at("_",afile[1])-1)) StartThread(Test(nind) // открываем одни и те же базы с разными Alias WaitForThreads() // в зависимости от nind ferase(puts+afile[1])==0 ENDIF next endif ThreadSleep(100) enddo RETURN nil ****************** PROCEDURE MyFuncA( ) DO WHILE inkey( 0.1 ) != 27 ENDDO lExit := .T. RETURN [/pre2]

Петр: Dima пишет: В чем разница ? Похоже и в том и другом случае все завершается коректно В таком контексте - да. Но нужно учесть, что функция WaitForThreads ( в Harbour hb_threadWaitForAll ) приостанавливает выполнение главного потока, дожидаясь пока не завершат свою роботу все остальные потоки. В случае, если до вызова WaitForThreads все вторичные потоки уже завершили свою роботу, функция просто немедленно завершит свое выполнение. Главный поток создается неявно и в главном потоке выполняется функция Main (_AppMain). Использование функции WaitForThreads в вторичных потоках (отличных от главного) не имеет смысла, так как функция просто немедленно возвратит управление вызывающему потоку ничего не делая. Иными словами использовать WaitForThreads можно только в функции Main (_AppMain). Функцию же JoinThread() можно вызывать как из главного, так и из вторичных потоков. Функция JoinThread() ( в Harbour hb_threadJoin ) приостанавливает выполнение того потока, из которого она была вызвана, дожидаясь пока не завершит свою роботу поток, указатель на который был передан функции в виде аргумента. В случае, если до вызова JoinThread( thread) поток thread уже завершил свою роботу, функция просто немедленно завершит свое выполнение. Будет ли верно работать такой код или нужно что-то поправить ? Нужно править. См. выше.

Петр: Dima пишет: Можно ли в функции MyFuncB() , стартовать еще потоки на выполнение (StartThread) ? Для чего нужна функция HB_MutexCreate() ? 1) Можно, только, ну ты сам понимаешь 2) Для разрешения возможных коллизий при одновременном доступе к ресурсам ( например, к переменным ) из разных потоков. Механизм чем-то похожий на блокировки записей, таблиц.

Петр: Dima пишет: ? AdsIsServerLoaded(CurDrive()+":\"+CurDir()+"\DBF\"+"data_nul.dbf") // локальный ADS , возвращает 0 Причем до вызова всех StartThread , AdsIsServerLoaded работает правильно Не могу подтвердить, AdsIsServerLoaded( cPath ) при доступном (существующем) cPath для локального ADS возвращает 1, как и положено. P.S. Имя файла ( AdsIsServerLoaded(CurDrive()+":\"+CurDir()+"\DBF\"+"data_nul.dbf") ) задавать не нужно, все равно оно при проверке отбрасывается.

Dima: Петр пишет: Не могу подтвердить, AdsIsServerLoaded( cPath ) при доступном (существующем) cPath для локального ADS возвращает 1, как и положено. В фунции запущенной через StartThread ? Грю же что проверил , не пашет. До StartThread вернет 1 В функции запущенной в поток вернет 0 ЗЫ Путь cPath одинаков и он существует ! Что касается имени файла , спасибо , поправлю !

Dima: Пример конечно грубый , но понятно где не пашет. Юзаем AdsSetServerType(3) // Local + Remote Ads ........ ? AdsIsServerLoaded(CurDrive()+":\"+CurDir()+"\DBF\") // ==1 threadB:=StartThread(@Test()) В функции Test ? AdsIsServerLoaded(CurDrive()+":\"+CurDir()+"\DBF\") // ==0 всегда в режиме MT (Xharbour)

Петр: Я тестировал на этом - ? res := AdsIsServerLoaded( CurDrive()+":\"+CurDir() ) == 1 [pre2]STATIC lExit // PROCEDURE main LOCAL threadA, threadB, threadC lExit := .F. threadC := StartThread( @TestAds() ) threadB := StartThread( @MyFuncB() ) threadA := StartThread( @MyFuncA() ) WaitForThreads() // RETURN /* */ STATIC FUNCTION MyFuncA( ) DO WHILE inkey( 0.1 ) != 27 ENDDO lExit := .T. // RETURN LastKey() /* */ STATIC FUNCTION MyFuncB( ) LOCAL nCounter, nI DO WHILE !lExit nCounter := 0 FOR nI := 1 TO 2 nCounter ++ NEXT nI ThreadSleep(20) END // RETURN nCounter /* */ FUNCTION TestAds( cDBF ) LOCAL cField, res IF cDbf == NIL cDbf := "test" ENDIF RddSetDefault( "ADSCDX" ) AdsSetServerType( 1 ) AdsSetFileType( 2 ) ? res := AdsIsServerLoaded( CurDrive()+":\"+CurDir() ) IF File( "adstest.dbf" ) FErase( "adstest.dbf" ) ENDIF USE (cDBF) ALIAS "MY" EXCLUSIVE IF ! File( "adstest.dbf" ) COPY STRUCTURE TO adstest ENDIF USE adstest ALIAS "MY2" DO WHILE RecCount() < 1000 ? "Copying..." APPEND ALL FROM test ENDDO cField := Lower( FieldName(1) ) INDEX ON &cField TO (cField) ThreadSleep(20) // RETURN res [/pre2]

Dima: Петр пишет: Я тестировал на этом - Xharbour ?

Dima: Петр пишет: RddSetDefault( "ADSCDX" ) AdsSetServerType( 1 ) AdsSetFileType( 2 ) По ходу эти вещи я объявил в основной процедуре (Main) , может в этом дело.............

Петр: Dima пишет: По ходу эти вещи я объявил в основной процедуре (Main) , может в этом дело............. Очень даже может быть Если так то 0 и ADSCDX/5033 Open error: test.

Петр: Dima пишет: Xharbour ? - угу

Петр: в Harbour - все Ok и так и так. И вообще в Harbour MT (и не только MT) на порядок лучше.

Dima: Петр пишет: И вообще в Harbour MT (и не только MT) на порядок лучше.

Dima: Петр Вроде чуть продвинулся. В примере ниже из потока threadB , запускаю 20 потоков и все корректно завершается на первый взгляд и без падений. Можешь прокоментировать или что то добавить ? [pre2] STATIC lExit PROCEDURE main local threadA, threadB cls lExit := .F. threadB := StartThread( @MyFuncB()) threadA := StartThread( @MyFuncA()) JoinThread( threadA ) JoinThread( threadB ) RETURN ************************* func MyFuncB() local nind local tst:=20 local anind:=array(tst) DO WHILE !lExit for nind=1 to tst anind[nind]:=StartThread(@Test(),nind) next for nind=1 to len(anind) if IsValidThread(anind[nind]) JoinThread(anind[nind]) endif next enddo ThreadSleep(20) RETURN nil ************** Func Test(nrow) local i for i=1 to 1000 DispOutAt(nRow,10,str(i,5)) next return nil ****************** Func MyFuncA( ) DO WHILE inkey( 0.1 ) != 27 ENDDO lExit := .T. RETURN nil [/pre2]

Dima: Чуть усложняем функцию MyFuncB ....полет нормальный однако [pre2] func MyFuncB() local nind local tst local anind DO WHILE !lExit tst:=HB_RandomInt(1,20) anind:=array(tst) for nind=1 to tst anind[nind]:=StartThread(@Test(),nind) next for nind=1 to len(anind) if IsValidThread(anind[nind]) JoinThread(anind[nind]) endif next enddo RETURN nil [/pre2]

Петр: Dima пишет: В примере ниже из потока threadB , запускаю 20 потоков и все корректно завершается на первый взгляд и без падений. Ну падений не должно быть, ты же используешь IsValidThread. Все довольно корректно написано.

Dima: И снова небольшая модификация [pre2] func MyFuncB() local nind local tst local anind DO WHILE !lExit tst:=HB_RandomInt(1,20) anind:=array(tst) for nind=1 to tst anind[nind]:=StartThread(@Test(),nind) ThreadSleep(20) // иначе IsValidThread не всегда вернет .T. next for nind=1 to len(anind) if IsValidThread(anind[nind]) JoinThread(anind[nind]) endif next enddo RETURN nil [/pre2] [pre2] Func Test(nrow) local i for i=1 to 1000 DispOutAt(nRow,10,str(i,5)) ThreadSleep(1) // что бы проц не грузило :) next return nil [/pre2]

Петр: Dima пишет: ThreadSleep(20) // иначе IsValidThread не всегда вернет .T. Да - в Harbour ThreadSleep не нужен, да и нет его , в xHarbour ThreadSleep сводится к банальному sleep. Поскольку Windows никогда не была системой реального времени, вызов ThreadSleep(nTimeOut) с nTimeOut < 20 не желателен, хотя и возможен.

Dima: Петр пишет: вызов ThreadSleep(nTimeOut) с nTimeOut < 20 не желателен, хотя и возможен. Не знал , учту. Спасибо !!!

Dima: Dima пишет: [pre2] for nind=1 to len(anind) if IsValidThread(anind[nind]) JoinThread(anind[nind]) endif next [/pre2] Подумалось тут. О чем говорит факт что IsValidThread вернет .F. , о том что данный поток закончен и нет смысла делать для него JoinThread ? Скажем есть 10 потоков , в 3-х из них IsValidThread вернул .F. и JoinThread не был выполнен , к каким последствиям это может привести ?

Петр: Dima пишет: О чем говорит факт что IsValidThread вернет .F. , о том что данный поток закончен и нет смысла делать для него JoinThread ? Нет, IsValidThread вернет .F. также в том случае по какой-то причине поток не инициализировался. Dima пишет: к каким последствиям это может привести Все зависит от задачи, порой к плачевным Выполнять JoinThread не обязательно, но ты, наверное, хотел бы контролировать поведение своей программы.

Dima: Петр пишет: Выполнять JoinThread не обязательно, но ты, наверное, хотел бы контролировать поведение своей программы. Конечно хочу ! Как это правильно сделать на Xharbour применительно к этому примеру ? [pre2] STATIC lExit PROCEDURE main local threadA, threadB cls lExit := .F. threadB := StartThread( @MyFuncB()) threadA := StartThread( @MyFuncA()) JoinThread( threadA ) JoinThread( threadB ) RETURN ************************* func MyFuncB() local nind local tst:=20 local anind:=array(tst) DO WHILE !lExit for nind=1 to tst anind[nind]:=StartThread(@Test(),nind) next for nind=1 to len(anind) if IsValidThread(anind[nind]) JoinThread(anind[nind]) endif next enddo ThreadSleep(20) RETURN nil ************** Func Test(nrow) local i for i=1 to 1000 DispOutAt(nRow,10,str(i,5)) next return nil ****************** Func MyFuncA( ) DO WHILE inkey( 0.1 ) != 27 ENDDO lExit := .T. RETURN nil [/pre2]

Петр: Я уже писал - этот пример достаточно корректный. Единственное, я, наверное, делал бы проверку IsValidThread не перед JoinThread, а после StartThread.

Dima: Петр пишет: Единственное, я, наверное, делал бы проверку IsValidThread не перед JoinThread, а после StartThread Сделать , сделал только это мало что дало......... [pre2] func MyFuncB() local nind local tst local anind DO WHILE !lExit tst:=20 anind:={} for nind=1 to tst eval({|x| x:=StartThread(@Test(),nind),aadd(anind,{x,IsValidThread(x)}) }) DispOutAt(nind,45,anind[len(anind)][2],"rb+/n") // видно что все потоки валидны next for nind=1 to len(anind) if anind[nind][2] .and. IsValidThread(anind[nind][1]) // если не делать IsValidThread , упадет прога...error.log ниже JoinThread(anind[nind][1]) DispOutAt(nind,20,anind[nind][1]) DispOutAt(nind,30,nind) else DispOutAt(nind,20,anind[nind][1],"r/n") // оказывается не все валидны , почему ? DispOutAt(nind,30,nind,"r/n") endif next enddo ThreadSleep(20) RETURN nil [/pre2] Subsystem Call ....: BASE System Code .......: 3012 Default Status ....: .F. Description .......: Given thread is not valid Operation .........: JOINTHREAD Arguments .........: [ 1] = Type: P Val: 9D25A4 Involved File .....: Dos Error Code ....: 0 Running threads ...: 3 VM thread ID ......: 3 OS thread ID ......: 2096

Петр: Если внимательно читать описание JoinThread If the thread <pThreadHandle> is already terminated, the function returns immediately and does not wait. ничего подобного не должно случаться, но в xHarbour многопоточность реализована достаточно неполно, как следствие, наверное, никем не используется и следовательно ошибки не исправляются. Так, что ипользуя IsValidThread с JoinThread ты просто отсеиваешь глюки xHarbour. Некоторое время назад на форуме comp.lang.xharbour была заочная дисскусия между Пржемеком и автором реализации многопоточности xHarbour (забыл как его зовут, итальянец), кстати теперь я что-то не могу ее найти, или удалили или просто не внимателен. Найди и почитай, очень познавательно для пользователей xHarbour. Так вот, по словам Пржемека многопоточность xHarbour можна считать декларативной и он не рекомендовал бы ее использовать в реальных бизнес проектах. Один пример, в отдельных случаях из за способа обращения к таблице динамических символов прога на xHarbour использующая МТ, может сама по себе валиться после нескольких часов работы, так, что написать прогу 24х7 не удастся. P.S. Я тебя когда спрашивал, не мешают ли тебе какие-то причины (религиозные, например) использовать Harbour?

Dima: Петр пишет: Так, что ипользуя IsValidThread с JoinThread ты просто отсеиваешь глюки xHarbour Хочешь сказать что тот же код без проверок (IsValidThread) будет работать в Harbour без падений ? ЗЫ rddads в Harbour адаптирован под старые версии ADS , типа 5-ой ?

Pasha: Dima пишет: rddads в Harbour адаптирован под старые версии ADS , типа 5-ой ? Во всяком случае последнее изменение: + Added support for ADS_USE_OEM_TRANSLATION for old ads versions. в Harbour оперативно портировали

Петр: Dima пишет: Хочешь сказать что тот же код без проверок (IsValidThread) будет работать в Harbour без падений ? Я уже писал, что портирование даного примера из xHarbour в Harbour - далось мне с трудом, непонятные глюки на ровном месте. [pre2]2008-10-07 09:33 UTC+0200 Viktor Szakats (harbour.01 syenar hu) * include/hbextern.ch * source/rtl/inkey.c + Added HB_KEYCLEAR() a documented function equivalent to "CLEAR TYPEAHEAD" command, or undocumented __KEYBOARD() function. * contrib/rddads/rddads.h * contrib/rddads/ads1.c + Added support for ADS_USE_OEM_TRANSLATION for old ads versions. Borrowed from xhb/Pavel Tsarenko. [/pre2]

Dima: Петр пишет: Harbour + MT: пример [pre2] #include "hbthread.ch" MEMVAR lExit // PROCEDURE main LOCAL threadA, threadB, xResult := NIL PUBLIC lExit := .F. threadB := hb_threadStart( HB_THREAD_INHERIT_PUBLIC, @MyFuncB() ) threadA := hb_threadStart( HB_THREAD_INHERIT_PUBLIC, @MyFuncA() ) *** __keyboard(chr(27)) // можно закомментировать hb_threadJoin( threadA, @xResult ) ? xResult hb_threadJoin( threadB, @xResult ) ? xResult // RETURN /* */ STATIC FUNCTION MyFuncA( ) DO WHILE inkey( 0.1 ) != 27 ENDDO lExit := .T. // RETURN LastKey() /* */ STATIC FUNCTION MyFuncB( ) LOCAL nCounter, nI DO WHILE !lExit nCounter := 0 FOR nI := 1 TO 10000 nCounter ++ NEXT nI END // RETURN nCounter [/pre2] Скачал и собрал Harbour. А вот данный пример собрать не могу. В Xharbour как то попроще это ;) Кинул пример в папку Tests , запускаем bld_b32.bat m1 /MT и получаем ошибку в 13 строке , аргумент error hb_threadJoin , хотя синтаксис верен. Пробнул собрать с помощью hbmake Результат Borland C++ 5.5.1 for Win32 Copyright (c) 1993, 2000 Borland obj\m1.c: Error E2451 obj\m1.c 25: Undefined symbol 'HB_FS_MEMVAR' Error E2141 obj\m1.c 25: Declaration syntax error Error E2190 obj\m1.c 25: Unexpected } Error E2190 obj\m1.c 25: Unexpected } Error E2040 obj\m1.c 25: Declaration terminated incorrectly Error E2190 obj\m1.c 25: Unexpected } Error E2190 obj\m1.c 25: Unexpected } Error E2040 obj\m1.c 25: Declaration terminated incorrectly Error E2451 obj\m1.c 38: Undefined symbol 'hb_vm_SymbolInit_M1' *** 9 errors in Compile ***

Петр: Dima пишет: Скачал и собрал Harbour make_b32.bat make_b32.bat install bld_b32.bat m1 /MT - неправильно нужно в bld_b32.bat добавить set HB_MT=MT можно также set C_USR= set PRG_USR= set HB_USER_LIBS=rddads hbcurl

Dima: Петр пишет: нужно в bld_b32.bat добавить set HB_MT=MT получил тот же результат Dima пишет: аргумент error hb_threadJoin

Петр: Дима Ты слинковал программу в ST режиме, отсюда и падения добавь таки set HB_MT=MT P.S. Для проверки в каком режиме работает HVM ST или MT используй hb_mtvm()

Dima: Петр пишет: добавь таки set HB_MT=MT Грю же что добавил ;) Странно но в батнике bld.bat эти строки не срабатывают похоже , временно сделал так rem if "%HB_MT%" == "MT" set _HBVM_LIB=hbvmmt rem if not "%HB_MT%" == "MT" set _HBVM_LIB=hbvm set _HBVM_LIB=hbvmmt Все собралось и работает отлично в отличие от Xharbour !!!

Dima: Петр Однако при 20 запущенных потоках проц грузится очень конкретно. Пришлось в цикл воткнуть hb_idleSleep(0.001). Может есть какой то другой способ разгрузки процессора ?

Петр: О процессоре - охотно верю. В реальной жизни, не в примере нужно вызывать hb_releaseCPU()

Dima: Петр Понял , спасибо. Пересобрал и оставил крутится пару часов. Надеюсь не свалится :)

Dima: Петр пишет: Так, что ипользуя IsValidThread с JoinThread IsValidThread реализован в Harbour ? PS Как крыску отключить в Harbour ? Так не катит request HB_NOMOUSE

Петр: Dima пишет: IsValidThread реализован в Harbour Нет, а зачем она тебе? Спрятать курсор? IMHO только WAPI ShowCursor() #pragma BEGINDUMP #include <windows.h> HB_FUNC( SHOWMOUSECURSOR ) { ShowCursor( hb_parl(1) ); } #pragma ENDDUMP

Dima: Петр пишет: Спрятать курсор? IMHO только WAPI ShowCursor() Спасибо , но не сработало. Петр пишет: Dima пишет: цитата: IsValidThread реализован в Harbour Нет, а зачем она тебе? Просто хотел подстраховаться от возможного вылета в hb_threadJoin(), так как задача будет работать 24 часа в сутки. И еще вопрос. [pre2] for i=1 to 20 hb_threadStart(@Test(),i) next [/pre2] Каждый поток обрабатывается в своей области памяти ? Не будет конфликта локальных и привате переменных объявленных в функции Test() ?

Петр: ShowCursor( .F. ) катит? Странно.. Проверяй thread на hb_isPointer(thread) != .F. Dima пишет: Каждый поток обрабатывается в своей области памяти ? Смотри tests\mt\mttest08.prg Локальных не будет, а там как напишешь , т.е. с какими параметрами вызовешь hb_threadStart. Статические переменные обьявляй как thread static (если нужно)

Dima: Петр Подскажи дружище что тут можно сделать ! [pre2] for nind=1 to 50 hb_threadStart(@Test(),nind) next Func Test(nid) USE test SHARED Alias &( "Test"+ Alltrim( Str(nId)) ) NEW USE test SHARED Alias &( "Test1"+ Alltrim( Str(nId)) ) NEW USE test SHARED Alias &( "Test2"+ Alltrim( Str(nId)) ) NEW USE test SHARED Alias &( "Test3"+ Alltrim( Str(nId)) ) NEW USE test SHARED Alias &( "Test4"+ Alltrim( Str(nId)) ) NEW * тут что то делаем * и в какой то момент можем получить такой то Alias не существует * при обращении к какой то базе. * Почему ? * Куда и какой костыль вставить ? :) close ("Test"+ Alltrim( Str(nId))) close ("Test1"+ Alltrim( Str(nId))) close ("Test2"+ Alltrim( Str(nId))) close ("Test3"+ Alltrim( Str(nId))) close ("Test4"+ Alltrim( Str(nId))) return nil [/pre2] PS ADS. Что интерестно , то работает то нет..........

Dima: Если вставить костыль , то работает , но это наверное не выход [pre2] for nind=1 to 50 hb_threadStart(@Test(),nind) hb_idleSleep(5) next [/pre2]

Петр: Dima пишет: for nind=1 to 50 hb_threadStart(@Test(),nind) next Это реальная ситуация? Тебе действительно нужно вызывать 50 потоков? И зачем одну базу открывать столько раз. По коду я вижу, что ты даже не проверяешь, успешно ли открыта база.

Dima: Петр пишет: Это реальная ситуация? Тебе действительно нужно вызывать 50 потоков? Ситуация почти реальна. Сколько зайдет запросов столько будет и потоков. Запросов может быть от 1 до 50 Открытие базы я конечно же проверяю , дал пример что бы ясно было чего делаю. Если хоть одна база не открыта я выхожу из функции Test. Возможно дело в кол-ве одновременно открываемых файлов ? Тогда что нужно исправить ? Реально в одном потоке я открываю 20 баз и 15 индексных файлов.

Петр: А упростить себе жизнь и держать таблицы открытыми?

Dima: Петр пишет: А упростить себе жизнь и держать таблицы открытыми? Не думал про это , теперь подумаю ! И все же почему падает пример ?

Петр: Хороший вопрос, но у меня сейчас нет на него ответа. Надо тестировать. Хотя бы найти, чей это косяк ADS или Harbour. Посмотрю на досуге. Но ясно одно, такие программы должны быть тщательно спроектированы и реализованы.

Dima: В реальном примере падает даже на 3 потоках (не всегда) с той же ошибкой "Alias не существует" При чем падает в разных местах и закономерности не обнаружил. Базы все открыты 100 % (по той схеме о которой писал выше) Есть причины не держать базы все время открытыми. Где то читал на форуме http://www.fivetechsoft.com/forums что ADS не работает в MT режиме или работает не корректно.....но пока не вижу ссылки на тему. PS В отличие от Xharbour , Ads спецом для MT режима я не пересобирал , все собралось и так. Возможно в этом причина ?

Dima: Dima пишет: [pre2] Func Test(nid) USE test SHARED Alias &( "Test"+ Alltrim( Str(nId)) ) NEW USE test SHARED Alias &( "Test1"+ Alltrim( Str(nId)) ) NEW USE test SHARED Alias &( "Test2"+ Alltrim( Str(nId)) ) NEW USE test SHARED Alias &( "Test3"+ Alltrim( Str(nId)) ) NEW USE test SHARED Alias &( "Test4"+ Alltrim( Str(nId)) ) NEW * тут что то делаем * и в какой то момент можем получить такой то Alias не существует * при обращении к какой то базе. * Почему ? * Куда и какой костыль вставить ? :) close ("Test"+ Alltrim( Str(nId))) close ("Test1"+ Alltrim( Str(nId))) close ("Test2"+ Alltrim( Str(nId))) close ("Test3"+ Alltrim( Str(nId))) close ("Test4"+ Alltrim( Str(nId))) return nil [/pre2] Опытным путем установил , что если nid локальная переменная то прога может падать. Если Private то не падает. Если так может упасть Func Test(nid) Так пока не упала ни разу ;) Func Test() param nid PS Рано радовался...............меньше стало падать но все равно падает

Петр: Dima пишет: В отличие от Xharbour , Ads спецом для MT режима я не пересобирал , все собралось и так. Возможно в этом причина ? Скорее всего нет, я склоняюсь к мысли, что это проблемы ADS - не успевает отрабатывать запросы. for nind=1 to 50 hb_threadStart(@Test(),nind) next с RDDCDX отрабатывает без проблем Меняй схему работы - запросы ставь в очередь и обрабатывай последовательно. И hb_idleSleep() - это не костыль. А вообще задача у тебя на каком процессоре крутится - есть реальная многопроцессорность (ядерность) или все средствами OS разруливается?

Dima: Петр пишет: Меняй схему работы - запросы ставь в очередь и обрабатывай последовательно Видимо так и придется делать , хотя задачу ставили что бы все крутилось одновременно. Есть около 50 коммерческих агентов которые ездят с ноутбуками и собирают заявки от своих клиентов. По мере необходимости каждый из агентов сбрасывает на ftp свои заявки + могут делать запросы на получение прайс листов , остатков , актуального справочника своих клиентов и тд и тп. Именно эти запросы и хотелось пустить в потоки..........но , похоже не выйдет так как ADS выбрыкивается. Жаль. Задача крутится на самом обычном процессоре под XP

Петр: Dima пишет: Задача крутится на самом обычном процессоре под XP Почитай в справке ADS - Number of Worker Threads. Для 50 рабочих потоков нужно, как минимум 4 CPU (физических или логических).

Dima: Петр Понял. Спасибо ! Буду обрабатывать запросы последовательно.

Dima: Глянул Ads_err.dbf , когда прога падала лезут одни и те же ошибки [pre2] THREAD_NUM ERR_CLASS ERR_CODE ADS_SOURCE SRC_LINE 111295936 0 16 dbf.c 269 111295936 0 128 dbf.c 270 111295936 7000 7040 dbf.c 280 111879232 0 16 dbf.c 269 111879232 0 128 dbf.c 270 111879232 7000 7040 dbf.c 280 [/pre2] Так и не понял что за ERR_CODE 128 , в доке не нашел.

полная версия страницы