115 lines
3.6 KiB
Markdown
115 lines
3.6 KiB
Markdown
---
|
||
title: "📋 Параллелизм или расписание в Crystal"
|
||
date: 2022-10-07T22:43:29+03:00
|
||
draft: false
|
||
tags: [crystal, development, tutorial]
|
||
---
|
||
|
||
## Выполнять код раз в 10 секунд?
|
||
|
||
Обычная задача в буднях говнокодера.
|
||
|
||
Про параллелизм в [Crystal](https://crystal-lang.org/) есть хорошая статья
|
||
[Concurrency vs. Parallelism](https://crystal-lang.org/reference/1.6/guides/concurrency.html).
|
||
|
||
В целом если её прочитать, то необходимость в прочтении этого руководства отпадает полностью.
|
||
Ничего нового ты здесь не узнаешь, однако я продолжу...
|
||
|
||
## Глубокий сон
|
||
|
||
[sleep](https://crystal-lang.org/api/1.6.0/toplevel.html#sleep%3ANil-class-method) —
|
||
Top Level метод, который блокирует текущий `fiber`\*
|
||
|
||
\* [Fiber](https://crystal-lang.org/api/1.6.0/Fiber.html) — это исполняемый блок кода, управляемый райнтаймом Crystal.
|
||
Концептуально Fiber похож на поток (thread), но с меньшими затратами и полностью внутренне связан с процессом Crystal.
|
||
Рантайм включает планировщик, который очевидно планирует выполнение волокон.
|
||
|
||
Связь между волокнами обычно осуществляется через [Channel](https://crystal-lang.org/api/1.6.0/Channel.html).
|
||
|
||
## Цикличное выполнение
|
||
|
||
Для реализации цикла в Crystal можно использовать оператор `while`:
|
||
|
||
```crystal
|
||
while p! "╭∩╮(Ο_Ο)╭∩╮".class
|
||
end
|
||
```
|
||
|
||
Или даже оператор `loop`:
|
||
|
||
```crystal
|
||
loop do
|
||
p! "╭∩╮(Ο_Ο)╭∩╮".class
|
||
end
|
||
```
|
||
|
||
А если запихонить в цикл метод `sleep`, то получим уже имитацию выполнения блока кода
|
||
по расписанию:
|
||
|
||
```crystal
|
||
loop do
|
||
p! "╭∩╮(Ο_Ο)╭∩╮".class
|
||
|
||
sleep 2
|
||
end
|
||
```
|
||
|
||
Но ты же наблюдательный и понял, что пока один loop/while не закончит выполнение,
|
||
второй цикл не запустится.
|
||
|
||
Вот для таких случаем и нужны Fiber или волокна, просто меня, но я буду называть их `Файберами`.
|
||
|
||
## Файберы
|
||
|
||
Попробуй запустить этот пример и посмотри что получится.
|
||
|
||
```crystal
|
||
spawn do
|
||
loop do
|
||
p! "╭∩╮(Ο_Ο)╭∩╮".class
|
||
end
|
||
end
|
||
|
||
spawn do
|
||
loop do
|
||
puts Time.local.to_unix
|
||
end
|
||
end
|
||
|
||
sleep
|
||
```
|
||
|
||
Тут я создал два файбера, в которых циклично выполняется некий код,
|
||
а главный процесс программы я зациклил методом `sleep`.
|
||
|
||
Удивительно, не правда ли?)
|
||
|
||
Запихониваем в циклы `sleep ` и получаем выполнение каждого файбера с разным интервалом.
|
||
|
||
## wrapper
|
||
|
||
Всё эту простыню можно оформить таким образом:
|
||
|
||
```crystal
|
||
def every(period : Time::Span, &block : -> T) forall T
|
||
spawn do
|
||
loop do
|
||
block.call
|
||
sleep period
|
||
end
|
||
end
|
||
end
|
||
|
||
every(2.seconds) {
|
||
puts "-@-@-"
|
||
}
|
||
|
||
every(4.seconds) {
|
||
puts "(-.-)Zzz..."
|
||
}
|
||
|
||
sleep
|
||
```
|
||
|
||
Жрёт это всё ~2Mb памяти.
|