W Cat - Язык программирования Euphoria. Справочное руководство

Комментарии:

Функция task_create() позволяет оформить новую задачу, но не запускает её на исполнение.

Каждая из задач имеет свой набор частных переменных и свой собственный стек вызова. Глобальные и местные переменные действуют для всех задач.

При обнаружении ошибки во время исполнения, отчёт будет включать информацию по всем задачам, с ошибочной задачей, идущей в списке первой.

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

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

Каждая задача имеет уникальный номер. Функция task_create() никогда не выдаёт повторный номер задачи, как это было ранее. Номера задач являются атомами с величиной вплоть до наибольшей доступной целочисленной величины (15 цифр).

Пример:

mytask = task_create(routine_id("myproc"), {5, 9, "ABC"})

См. также:

task_schedule, task_yield, task_suspend, task_self

task_list

Синтаксис:

s = task_list()

Описание:

Выдаёт ряд, содержащий номера всех активных или приостановленных задач.

Комментарии:

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

Пример:

sequence tasks

tasks = task_list()

for i = 1 to length(tasks) do

if task_status(tasks[i]) 0 then

printf(1, "задача %d активна\n", tasks[i])

end if

end for

См. также:

task_status, task_create, task_schedule, task_yield, task_suspend

task_schedule

Синтаксис:

task_schedule(a, x)

Описание:

Включает задачу номер a в план диспетчера, задаваемый аргументом x. Аргумент a должен быть получен как результат из функции task_create(). Если x является положительным атомом, это означает, что задача a является задачей общего времени и диспетчер должен x раз подряд обеспечить её выполнение, прежде чем перейти к другим задачам. Если x является рядом, это должен быть двухэлементный ряд {min, max}, в котором оба элемента больше нуля или равны нулю, а min и max дают минимальное и максимальное время, в секундах, которое необходимо выждать перед исполнением задачи реального времени a. Величины min и max также устанавливают временной интервал между последовательными запусками задачи a, если он не будет изменён повторным вызовом task_schedule() или task_suspend().

Комментарии:

Диспетчер задач, встроенный в систему исполнения программы Euphoria, будет использовать аргумент плана x как руководство к действию при работе с данной задачей. Может случиться так, что не всегда окажутся возможными заданное число последовательных запусков или заданные временные рамки задачи. Например, задача может решаться так долго перед отдачей управления диспетчеру, что другая задача не получит заданного временного окна.

Задачи реального времени имеют более высокий приоритет. Задачи общего времени выполняются, когда нет задач реального времени, готовых к выполнению. Задача может переключаться между режимами выполнения реального и общего времени. Это всё зависит от последнего вызова task_schedule() для данной задачи. Диспетчер никогда не запустит задачу реального времени до открытия её временного окна (величина min), и он пытается не допустить пропуска временного окна (величина max).

Чтобы повысить точность временных рамок, вы можете задать одну и ту же величину для min и для max. Тем не менее, задавая некоторый промежуток, вы добавляете диспетчеру гибкости. Это позволяет ему выполнять план задач более эффективно, избегая непродуктивных задержек. Когда диспетчеру требуется задержка, он вызывает sleep(), если задержка не слишком короткая. Использование sleep() позволяет операционной системе выполнять другие программы.

Величины min и max могут быть дробными. Если величина min меньше, чем разрешение часов диспетчера (в настоящее время 0.01 секунды под Windows и Linux/FreeBSD, и 0.55 секунды под DOS, если не вызывалась tick_rate()), точное диспетчирование не может быть выполнено, но диспетчер будет пытаться запустить задачу несколько раз подряд, чтобы приблизиться к заданному плану. Например, если вы задали время min равным 0.002 секунды, диспетчер будет пытаться запустить вашу задачу .01/.002 = 5 раз подряд, прежде чем ждать следующего тика часов через .01 секунды. Во время следующих 0.01 секунды он будет выполнять вашу задачу ещё (до) следующих 5 раз и так далее, считая, что ваша задача может быть завершена 5 раз за один тик его часов.

Для задач общего времени увеличение аргумента x будет увеличивать процент времени процессора, отдаваемого для выбранной задачи, при уменьшении этого процента для других задач общего времени. При этом эффективность программы в целом возрастёт, так как каждое переключение задач само по себе требует некоторого небольщого времени. Вызов task_yield(), когда та же самая задача продолжает выполняться, занимает меньше времени. Тем не менее, данный приём не всегда применим, так как может блокировать выполнение других задач общего времени на длительные периоды времени. Имейте в виду, что задачи реального времени всегда имеют приоритет перед любым task_yield(), если достигнуто время их активации.

По старту программы исполняется единственная задача. Её номер равен 0, и изначально это задача общего времени, которой разрешен 1 запуск на task_yield(). Другие задачи не могут выполняться, пока задача номер 0 не выполнит task_yield().

Если задача номер 0 (высшего уровня) достигает конца главного файла, вся программа считается исполненной и останавливается, независимо от того, что другие задачи всё ещё могут быть активными.

Если диспетчер не находит активных задач, т.е. в программе не осталось задач, которые следует поставить вновь на выполнение (в плане нет даже задачи номер 0), он останавливает программу с кодом окончания 0, наподобие abort(0).

Пример:

-- Задача t1 будет выполнена до 10 раз подряд, прежде чем

-- другим задачам общего времени будет отдано управление. Если управление

-- требуется задаче реального времени, t1 потеряет управление в её пользу.

task_schedule(t1, 10)

-- Задача t2 будет выполняться некоторое время между 4-ой и 5-ой секундами,

-- наступившими после текущего момента. Если не изменить план для t2, она будет

-- запускаться через каждые 4..5 секунд и в дальнейшем.

task_schedule(t2, {4, 5})

См. также:

task_create, task_yield, task_suspend, task_suspend

task_self

Синтаксис:

a = task_self()

Описание:

Выдаёт номер текущей задачи.

Комментарии:

Этот номер может понадобиться, если в задаче возникла необходимость перепланировать, приостановить или прекратить саму себя.

Пример:

-- перепланировать себя

task_schedule(task_self(), {5.9, 6.0})