Elixir: Знакомство с процессами
Весь Elixir код запускается в рамках процесса. Важно понимать, что процесс в Elixir не является аналогией процесса операционной системы.
Процессы в Elixir являются зелеными потоками (green threads) - это более легковесные процессы, чем в операционной системе, которые выполняются в рамках виртуальной машины языка программирования. В случае Elixir это BEAM. Внутри виртуальной машины выделяются отдельные планировщики, как и в операционной системе, которые следят за тем, чтобы каждый процесс работал определенный квант времени, например 4 миллисекунды. Благодаря такой отлаженной работы планировщиков нагрузка на процессор распределяется более плавно относительно каждого из ядер, то есть ситуации, когда одно ядро нагружено сильнее другого возникают намного реже. По сути, BEAM реализует на практике вытесняющую многозадачность.
Процессы изолированы и выполняются конкурентно относительно друг друга. Общаются процессы между собой через сообщения, забавный факт, что первая предложенная Аланом Кеем модель ООП как раз описывалась как множество объектов с внутренним состоянием, которые коммуницируют между собой через сообщения.
Из-за легковесности процессов, зачастую в Elixir приложениях запущенны сотни, а то и тысячи процессов. Для создания процесса используем функцию spawn:
spawn(fn -> 2 * 2 end)
# => #PID<0.43.0>
# создадим 100 тысяч процессов
processes = 0..100_000 |> Enum.map(fn _ -> spawn(fn -> 2 + 2 end) end)
# => много иднтификаторов процессов
hd(processes)
# => #PID<0.5249.9>
List.last(processes)
# => #PID<0.6945.12>
Функция spawn принимает аргументом функцию, которую запускает в отдельном процессе. Заметьте, что вызов spawn возвращает не результат выполнения переданной функции, а идентификатор процесса (process identifier) или ПИД (PID). Процесс, который был создан в предыдущем примере, после выполнения функции завершился.
pid = spawn(fn -> 2 * 2 end)
# => #PID<0.44.0>
Process.alive?(pid)
# => false
С помощью функции self мы можем узнать идентификатор нынешнего процесса, в котором была вызвана функция:
self()
# => #PID<0.41.0>
Process.alive?(self())
# => true
Задание
Создайте функцию run_in_process, которая принимает функцию и создает процесс, который выполняет эту функцию:
Solution.run_in_process(fn -> String.upcase("code basics") end)
# => #PID<0.42.0>
Solution.run_in_process(fn -> Process.sleep(1000) end)
# => #PID<0.43.0>
Полезное
Упражнение не проходит проверку — что делать? 😶
Если вы зашли в тупик, то самое время задать вопрос в «Обсуждениях». Как правильно задать вопрос:
- Обязательно приложите вывод тестов, без него практически невозможно понять что не так, даже если вы покажете свой код. Программисты плохо исполняют код в голове, но по полученной ошибке почти всегда понятно, куда смотреть.
В моей среде код работает, а здесь нет 🤨
Тесты устроены таким образом, что они проверяют решение разными способами и на разных данных. Часто решение работает с одними входными данными, но не работает с другими. Чтобы разобраться с этим моментом, изучите вкладку «Тесты» и внимательно посмотрите на вывод ошибок, в котором есть подсказки.
Мой код отличается от решения учителя 🤔
Это нормально 🙆, в программировании одну задачу можно выполнить множеством способов. Если ваш код прошел проверку, то он соответствует условиям задачи.
В редких случаях бывает, что решение подогнано под тесты, но это видно сразу.
Прочитал урок — ничего не понятно 🙄
Создавать обучающие материалы, понятные для всех без исключения, довольно сложно. Мы очень стараемся, но всегда есть что улучшать. Если вы встретили материал, который вам непонятен, опишите проблему в «Обсуждениях». Идеально, если вы сформулируете непонятные моменты в виде вопросов. Обычно нам нужно несколько дней для внесения правок.
Кстати, вы тоже можете участвовать в улучшении курсов: внизу есть ссылка на исходный код уроков, который можно править прямо из браузера.
Ваше упражнение проверяется по этим тестам
1defmodule Test do
2 use ExUnit.Case
3
4 test "run_in_process work" do
5 assert Solution.run_in_process(fn -> 2 + 2 end) |> is_pid()
6 assert Solution.run_in_process(fn -> "hello world" end) |> is_pid()
7 end
8end
9Решение учителя откроется через:
